This is an automated email from the ASF dual-hosted git repository.
tustvold pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git
The following commit(s) were added to refs/heads/master by this push:
new 3073a26bc Update vendored protobuf (#1869)
3073a26bc is described below
commit 3073a26bc1f28f799e1034306e8d6df40364ec69
Author: Raphael Taylor-Davies <[email protected]>
AuthorDate: Mon Jun 13 22:29:01 2022 +0100
Update vendored protobuf (#1869)
---
arrow-flight/src/arrow.flight.protocol.rs | 45 ++++++++++++++++---------------
1 file changed, 23 insertions(+), 22 deletions(-)
diff --git a/arrow-flight/src/arrow.flight.protocol.rs
b/arrow-flight/src/arrow.flight.protocol.rs
index bbca033fd..c76469b39 100644
--- a/arrow-flight/src/arrow.flight.protocol.rs
+++ b/arrow-flight/src/arrow.flight.protocol.rs
@@ -229,7 +229,7 @@ pub mod flight_service_client {
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
- T::ResponseBody: Default + Body<Data = Bytes> + Send + 'static,
+ T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
@@ -242,6 +242,7 @@ pub mod flight_service_client {
) -> FlightServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
+ T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
@@ -278,9 +279,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoStreamingRequest<Message =
super::HandshakeRequest>,
) -> Result<
-
tonic::Response<tonic::codec::Streaming<super::HandshakeResponse>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::HandshakeResponse>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
@@ -307,9 +308,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoRequest<super::Criteria>,
) -> Result<
- tonic::Response<tonic::codec::Streaming<super::FlightInfo>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::FlightInfo>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
@@ -388,9 +389,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoRequest<super::Ticket>,
) -> Result<
- tonic::Response<tonic::codec::Streaming<super::FlightData>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::FlightData>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
@@ -417,9 +418,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoStreamingRequest<Message =
super::FlightData>,
) -> Result<
- tonic::Response<tonic::codec::Streaming<super::PutResult>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::PutResult>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
@@ -445,9 +446,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoStreamingRequest<Message =
super::FlightData>,
) -> Result<
- tonic::Response<tonic::codec::Streaming<super::FlightData>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::FlightData>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
@@ -474,9 +475,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoRequest<super::Action>,
) -> Result<
- tonic::Response<tonic::codec::Streaming<super::Result>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::Result>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
@@ -500,9 +501,9 @@ pub mod flight_service_client {
&mut self,
request: impl tonic::IntoRequest<super::Empty>,
) -> Result<
- tonic::Response<tonic::codec::Streaming<super::ActionType>>,
- tonic::Status,
- > {
+ tonic::Response<tonic::codec::Streaming<super::ActionType>>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
