Method OutputStreamPipe

libminifi/include/io/StreamPipe.h:95–95

class OutputStreamPipe : public OutputStreamCallback {
 public:
  explicit OutputStreamPipe(std::shared_ptr<io::InputStream> input) : input_(std::move(input)) {}

  int64_t process(const std::shared_ptr<io::BaseStream>& stream) override {
    return internal::pipe(input_, stream);