Push a stream to the flight service associated with a particular flight stream.
(
&mut self,
request: impl tonic::IntoStreamingRequest<Message = FlightData>,
)
| 293 | |
| 294 | /// Push a stream to the flight service associated with a particular flight stream. |
| 295 | pub async fn do_put( |
| 296 | &mut self, |
| 297 | request: impl tonic::IntoStreamingRequest<Message = FlightData>, |
| 298 | ) -> Result<Streaming<PutResult>> { |
| 299 | let req = self.set_request_headers(request.into_streaming_request())?; |
| 300 | Ok(self.flight_client.do_put(req).await?.into_inner()) |
| 301 | } |
| 302 | |
| 303 | /// DoAction allows a flight client to do a specific action against a flight service |
| 304 | pub async fn do_action( |
no test coverage detected