Method Next

cpp/src/arrow/flight/flight_test.cc:1535–1541

  }

  arrow::Result<FlightPayload> Next() override {
    auto batch = RecordBatch::Make(schema_, 0, ArrayVector{});
    FlightPayload payload;
    RETURN_NOT_OK(ipc::GetRecordBatchPayload(*batch, ipc::IpcWriteOptions::Defaults(),
                                             &payload.ipc_message));
    return payload;
  }

 private:
  std::shared_ptr<Schema> schema_;