made a StreamSource operator and added a LocalFileTap for debugging