Switch to through from through2

Through2 emits end after _flush function is completed. This causes wrong interpretation of end of the stream in orchestrator. Through in other hand give possibility to not emit `end`, if something goes wrong in flush function.