Method process

test/anyflow/test_channel.cpp:41–45

struct ChannelInputProcessor : public GraphProcessor {
  virtual int process() noexcept override {
    enter_promise.set_value(::std::move(a));
    leave_future.get();
    return 0;
  }

  static ::std::promise<ChannelConsumer<::std::string>> enter_promise;
  static ::std::future<ChannelConsumer<::std::string>> enter_future;