commit e381a72703c1565fa186cd21629bc77c2395035e
author Neville Dipale <nevilledips@gmail.com> Wed Apr 01 18:12:17 2020 -0400
committer Benjamin Kietzman <bengilgit@gmail.com> Wed Apr 01 18:12:17 2020 -0400
tree aede8823031e6f16ad694f8d3a673cdca3d3362d
parent 2a2a9aed55e2e91033616d1f4839b6ed1f2f45df

ARROW-8308: [Rust] Implement DoExchange on examples

Closes #6800 from nevi-me/ARROW-8308

Authored-by: Neville Dipale <nevilledips@gmail.com>
Signed-off-by: Benjamin Kietzman <bengilgit@gmail.com>

rust/arrow-flight/examples/server.rs

diff --git a/rust/arrow-flight/examples/server.rs b/rust/arrow-flight/examples/server.rs
index b71ad78..6651e39 100644
--- a/rust/arrow-flight/examples/server.rs
+++ b/rust/arrow-flight/examples/server.rs
@@ -46,6 +46,8 @@
     >;
     type ListActionsStream =
         Pin<Box<dyn Stream<Item = Result<ActionType, Status>> + Send + Sync + 'static>>;
+    type DoExchangeStream =
+        Pin<Box<dyn Stream<Item = Result<FlightData, Status>> + Send + Sync + 'static>>;
 
     async fn handshake(
         &self,
@@ -102,6 +104,13 @@
     ) -> Result<Response<Self::ListActionsStream>, Status> {
         Err(Status::unimplemented("Not yet implemented"))
     }
+
+    async fn do_exchange(
+        &self,
+        _request: Request<Streaming<FlightData>>,
+    ) -> Result<Response<Self::DoExchangeStream>, Status> {
+        Err(Status::unimplemented("Not yet implemented"))
+    }
 }
 
 #[tokio::main]

rust/datafusion/examples/flight_server.rs

diff --git a/rust/datafusion/examples/flight_server.rs b/rust/datafusion/examples/flight_server.rs
index 30afa5d..b4592ba 100644
--- a/rust/datafusion/examples/flight_server.rs
+++ b/rust/datafusion/examples/flight_server.rs
@@ -54,6 +54,8 @@
     >;
     type ListActionsStream =
         Pin<Box<dyn Stream<Item = Result<ActionType, Status>> + Send + Sync + 'static>>;
+    type DoExchangeStream =
+        Pin<Box<dyn Stream<Item = Result<FlightData, Status>> + Send + Sync + 'static>>;
 
     async fn get_schema(
         &self,
@@ -163,6 +165,13 @@
     ) -> Result<Response<Self::ListActionsStream>, Status> {
         Err(Status::unimplemented("Not yet implemented"))
     }
+
+    async fn do_exchange(
+        &self,
+        _request: Request<Streaming<FlightData>>,
+    ) -> Result<Response<Self::DoExchangeStream>, Status> {
+        Err(Status::unimplemented("Not yet implemented"))
+    }
 }
 
 fn to_tonic_err(e: &datafusion::error::ExecutionError) -> Status {