Method InputStreamPipe

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

class InputStreamPipe : public InputStreamCallback {
 public:
  explicit InputStreamPipe(std::shared_ptr<io::OutputStream> output) : output_(std::move(output)) {}

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