// @generated by Thrift for thrift/compiler/test/fixtures/stream/src/module.thrift // This file is probably not the place you want to edit! //! Client implementation for each service in `module`. #![recursion_limit = "100000000"] #![allow(non_camel_case_types, non_snake_case, non_upper_case_globals, unused_crate_dependencies, unused_imports, clippy::all)] pub mod mock; #[doc(inline)] pub use :: as types; pub mod errors { #[doc(inline)] pub use ::::errors::pub_sub_streaming_service; #[doc(inline)] #[allow(ambiguous_glob_reexports)] pub use ::::errors::pub_sub_streaming_service::*; } pub(crate) use crate as client; pub(crate) use ::::services; // Used by Thrift-generated code to implement service inheritance. #[doc(hidden)] #[deprecated] pub mod dependencies { } /// Client definitions for `PubSubStreamingService`. pub struct PubSubStreamingServiceImpl { transport: T, _phantom: ::std::marker::PhantomData (P, S)>, } impl PubSubStreamingServiceImpl where P: ::fbthrift::Protocol, T: ::fbthrift::Transport, P::Frame: ::fbthrift::Framing>, ::fbthrift::ProtocolEncoded

: ::fbthrift::BufMutExt>, P::Deserializer: ::std::marker::Send, S: ::fbthrift::help::Spawner, { pub fn new( transport: T, ) -> Self { Self { transport, _phantom: ::std::marker::PhantomData, } } pub fn transport(&self) -> &T { &self.transport } fn _returnstream_impl( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.returnstream"; } let args = self::Args_PubSubStreamingService_returnstream { i32_from: arg_i32_from, i32_to: arg_i32_to, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("returnstream", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.returnstream")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::ReturnstreamStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::ReturnstreamStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::ReturnstreamStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::ReturnstreamResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<(), crate::errors::pub_sub_streaming_service::ReturnstreamError> = ::std::convert::From::from(res); let res = initial.map(move |_| new_stream); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.returnstream")) .boxed() } fn _streamthrows_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.streamthrows"; } let args = self::Args_PubSubStreamingService_streamthrows { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("streamthrows", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.streamthrows")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::StreamthrowsStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::StreamthrowsStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::StreamthrowsStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::StreamthrowsResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<(), crate::errors::pub_sub_streaming_service::StreamthrowsError> = ::std::convert::From::from(res); let res = initial.map(move |_| new_stream); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.streamthrows")) .boxed() } fn _servicethrows_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.servicethrows"; } let args = self::Args_PubSubStreamingService_servicethrows { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("servicethrows", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.servicethrows")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::ServicethrowsStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::ServicethrowsStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::ServicethrowsStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::ServicethrowsResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<(), crate::errors::pub_sub_streaming_service::ServicethrowsError> = ::std::convert::From::from(res); let res = initial.map(move |_| new_stream); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.servicethrows")) .boxed() } fn _servicethrows2_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.servicethrows2"; } let args = self::Args_PubSubStreamingService_servicethrows2 { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("servicethrows2", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.servicethrows2")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::Servicethrows2StreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::Servicethrows2StreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::Servicethrows2StreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::Servicethrows2ResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<(), crate::errors::pub_sub_streaming_service::Servicethrows2Error> = ::std::convert::From::from(res); let res = initial.map(move |_| new_stream); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.servicethrows2")) .boxed() } fn _boththrows_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.boththrows"; } let args = self::Args_PubSubStreamingService_boththrows { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("boththrows", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.boththrows")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::BoththrowsStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::BoththrowsStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::BoththrowsStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::BoththrowsResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<(), crate::errors::pub_sub_streaming_service::BoththrowsError> = ::std::convert::From::from(res); let res = initial.map(move |_| new_stream); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.boththrows")) .boxed() } fn _responseandstreamstreamthrows_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.responseandstreamstreamthrows"; } let args = self::Args_PubSubStreamingService_responseandstreamstreamthrows { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("responseandstreamstreamthrows", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.responseandstreamstreamthrows")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::ResponseandstreamstreamthrowsResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError> = ::std::convert::From::from(res); let res = initial.map(move |initial| (initial, new_stream)); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.responseandstreamstreamthrows")) .boxed() } fn _responseandstreamservicethrows_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.responseandstreamservicethrows"; } let args = self::Args_PubSubStreamingService_responseandstreamservicethrows { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("responseandstreamservicethrows", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.responseandstreamservicethrows")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::ResponseandstreamservicethrowsResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError> = ::std::convert::From::from(res); let res = initial.map(move |initial| (initial, new_stream)); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.responseandstreamservicethrows")) .boxed() } fn _responseandstreamboththrows_impl( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.responseandstreamboththrows"; } let args = self::Args_PubSubStreamingService_responseandstreamboththrows { foo: arg_foo, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("responseandstreamboththrows", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.responseandstreamboththrows")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::ResponseandstreamboththrowsStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::ResponseandstreamboththrowsStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::ResponseandstreamboththrowsResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError> = ::std::convert::From::from(res); let res = initial.map(move |initial| (initial, new_stream)); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.responseandstreamboththrows")) .boxed() } fn _returnstreamFast_impl( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>> { use ::const_cstr::const_cstr; use ::tracing::Instrument as _; use ::futures::FutureExt as _; use ::futures::StreamExt as _; use ::fbthrift::Deserialize as _; const_cstr! { SERVICE_NAME = "PubSubStreamingService"; SERVICE_METHOD_NAME = "PubSubStreamingService.returnstreamFast"; } let args = self::Args_PubSubStreamingService_returnstreamFast { i32_from: arg_i32_from, i32_to: arg_i32_to, _phantom: ::std::marker::PhantomData, }; let transport = self.transport(); // need to do call setup outside of async block because T: Transport isn't Send let request_env = match ::fbthrift::help::serialize_request_envelope::("returnstreamFast", &args) { ::std::result::Result::Ok(res) => res, ::std::result::Result::Err(err) => return ::futures::future::err(err.into()).boxed(), }; let call_stream = transport .call_stream(SERVICE_NAME.as_cstr(), SERVICE_METHOD_NAME.as_cstr(), request_env, rpc_options) .instrument(::tracing::trace_span!("call_stream", method = "PubSubStreamingService.returnstreamFast")); async move { let (initial, stream) = call_stream.await?; let new_stream = stream.then(|item_res| { async move { match item_res { ::std::result::Result::Err(err) => ::std::result::Result::Err(crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError::from(err)), ::std::result::Result::Ok(item_enc) => { let res = S::spawn(move || { match item_enc { ::fbthrift::ClientStreamElement::Reply(payload) => { let mut de = P::deserializer(payload); crate::services::pub_sub_streaming_service::ReturnstreamFastStreamExn::read(&mut de) } ::fbthrift::ClientStreamElement::ApplicationEx(payload) => { let mut de = P::deserializer(payload); ::fbthrift::ApplicationException::read(&mut de).map(crate::services::pub_sub_streaming_service::ReturnstreamFastStreamExn::ApplicationException) } } }).await?; let item: ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError> = ::std::convert::From::from(res); item } } } }) .boxed(); let de = P::deserializer(initial); let res: crate::services::pub_sub_streaming_service::ReturnstreamFastResponseExn = ::fbthrift::help::async_deserialize_response_envelope::(de).await?.0?; let initial: ::std::result::Result<(), crate::errors::pub_sub_streaming_service::ReturnstreamFastError> = ::std::convert::From::from(res); let res = initial.map(move |_| new_stream); res } .instrument(::tracing::info_span!("stream", method = "PubSubStreamingService.returnstreamFast")) .boxed() } } pub trait PubSubStreamingService: ::std::marker::Send { fn returnstream( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>>; fn streamthrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>>; fn servicethrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>>; fn servicethrows2( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>>; fn boththrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>>; fn responseandstreamstreamthrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>>; fn responseandstreamservicethrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>>; fn responseandstreamboththrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>>; fn returnstreamFast( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>>; } pub trait PubSubStreamingServiceExt: PubSubStreamingService where T: ::fbthrift::Transport, { fn returnstream_with_rpc_opts( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>>; fn streamthrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>>; fn servicethrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>>; fn servicethrows2_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>>; fn boththrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>>; fn responseandstreamstreamthrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>>; fn responseandstreamservicethrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>>; fn responseandstreamboththrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>>; fn returnstreamFast_with_rpc_opts( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>>; fn transport(&self) -> &T; } struct Args_PubSubStreamingService_returnstream<'a> { i32_from: ::std::primitive::i32, i32_to: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_returnstream<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.returnstream"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("i32_from", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.i32_from, p); p.write_field_end(); p.write_field_begin("i32_to", ::fbthrift::TType::I32, 2i16); ::fbthrift::Serialize::write(&self.i32_to, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_streamthrows<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_streamthrows<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.streamthrows"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_servicethrows<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_servicethrows<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.servicethrows"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_servicethrows2<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_servicethrows2<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.servicethrows2"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_boththrows<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_boththrows<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.boththrows"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_responseandstreamstreamthrows<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_responseandstreamstreamthrows<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.responseandstreamstreamthrows"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_responseandstreamservicethrows<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_responseandstreamservicethrows<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.responseandstreamservicethrows"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_responseandstreamboththrows<'a> { foo: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_responseandstreamboththrows<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.responseandstreamboththrows"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("foo", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.foo, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } struct Args_PubSubStreamingService_returnstreamFast<'a> { i32_from: ::std::primitive::i32, i32_to: ::std::primitive::i32, _phantom: ::std::marker::PhantomData<&'a ()>, } impl<'a, P: ::fbthrift::ProtocolWriter> ::fbthrift::Serialize

for self::Args_PubSubStreamingService_returnstreamFast<'a> { #[inline] #[::tracing::instrument(skip_all, level = "trace", name = "serialize_args", fields(method = "PubSubStreamingService.returnstreamFast"))] fn write(&self, p: &mut P) { p.write_struct_begin("args"); p.write_field_begin("i32_from", ::fbthrift::TType::I32, 1i16); ::fbthrift::Serialize::write(&self.i32_from, p); p.write_field_end(); p.write_field_begin("i32_to", ::fbthrift::TType::I32, 2i16); ::fbthrift::Serialize::write(&self.i32_to, p); p.write_field_end(); p.write_field_stop(); p.write_struct_end(); } } impl PubSubStreamingService for PubSubStreamingServiceImpl where P: ::fbthrift::Protocol, T: ::fbthrift::Transport, P::Frame: ::fbthrift::Framing>, ::fbthrift::ProtocolEncoded

: ::fbthrift::BufMutExt>, P::Deserializer: ::std::marker::Send, S: ::fbthrift::help::Spawner, { fn returnstream( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>> { let rpc_options = T::RpcOptions::default(); self._returnstream_impl( arg_i32_from, arg_i32_to, rpc_options, ) } fn streamthrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>> { let rpc_options = T::RpcOptions::default(); self._streamthrows_impl( arg_foo, rpc_options, ) } fn servicethrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>> { let rpc_options = T::RpcOptions::default(); self._servicethrows_impl( arg_foo, rpc_options, ) } fn servicethrows2( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>> { let rpc_options = T::RpcOptions::default(); self._servicethrows2_impl( arg_foo, rpc_options, ) } fn boththrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>> { let rpc_options = T::RpcOptions::default(); self._boththrows_impl( arg_foo, rpc_options, ) } fn responseandstreamstreamthrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>> { let rpc_options = T::RpcOptions::default(); self._responseandstreamstreamthrows_impl( arg_foo, rpc_options, ) } fn responseandstreamservicethrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>> { let rpc_options = T::RpcOptions::default(); self._responseandstreamservicethrows_impl( arg_foo, rpc_options, ) } fn responseandstreamboththrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>> { let rpc_options = T::RpcOptions::default(); self._responseandstreamboththrows_impl( arg_foo, rpc_options, ) } fn returnstreamFast( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>> { let rpc_options = T::RpcOptions::default(); self._returnstreamFast_impl( arg_i32_from, arg_i32_to, rpc_options, ) } } impl PubSubStreamingServiceExt for PubSubStreamingServiceImpl where P: ::fbthrift::Protocol, T: ::fbthrift::Transport, P::Frame: ::fbthrift::Framing>, ::fbthrift::ProtocolEncoded

: ::fbthrift::BufMutExt>, P::Deserializer: ::std::marker::Send, S: ::fbthrift::help::Spawner, { fn returnstream_with_rpc_opts( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>> { self._returnstream_impl( arg_i32_from, arg_i32_to, rpc_options, ) } fn streamthrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>> { self._streamthrows_impl( arg_foo, rpc_options, ) } fn servicethrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>> { self._servicethrows_impl( arg_foo, rpc_options, ) } fn servicethrows2_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>> { self._servicethrows2_impl( arg_foo, rpc_options, ) } fn boththrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>> { self._boththrows_impl( arg_foo, rpc_options, ) } fn responseandstreamstreamthrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>> { self._responseandstreamstreamthrows_impl( arg_foo, rpc_options, ) } fn responseandstreamservicethrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>> { self._responseandstreamservicethrows_impl( arg_foo, rpc_options, ) } fn responseandstreamboththrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>> { self._responseandstreamboththrows_impl( arg_foo, rpc_options, ) } fn returnstreamFast_with_rpc_opts( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>> { self._returnstreamFast_impl( arg_i32_from, arg_i32_to, rpc_options, ) } fn transport(&self) -> &T { self.transport() } } #[allow(deprecated)] impl<'a, S> PubSubStreamingService for S where S: ::std::convert::AsRef, S: ::std::marker::Send, { fn returnstream( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>> { self.as_ref().returnstream( arg_i32_from, arg_i32_to, ) } fn streamthrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>> { self.as_ref().streamthrows( arg_foo, ) } fn servicethrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>> { self.as_ref().servicethrows( arg_foo, ) } fn servicethrows2( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>> { self.as_ref().servicethrows2( arg_foo, ) } fn boththrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>> { self.as_ref().boththrows( arg_foo, ) } fn responseandstreamstreamthrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>> { self.as_ref().responseandstreamstreamthrows( arg_foo, ) } fn responseandstreamservicethrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>> { self.as_ref().responseandstreamservicethrows( arg_foo, ) } fn responseandstreamboththrows( &self, arg_foo: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>> { self.as_ref().responseandstreamboththrows( arg_foo, ) } fn returnstreamFast( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>> { self.as_ref().returnstreamFast( arg_i32_from, arg_i32_to, ) } } #[allow(deprecated)] impl PubSubStreamingServiceExt for S where S: ::std::convert::AsRef, S: ::std::convert::AsRef + 'static>, S: ::std::marker::Send, T: ::fbthrift::Transport, { fn returnstream_with_rpc_opts( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamError>> { >>::as_ref(self).returnstream_with_rpc_opts( arg_i32_from, arg_i32_to, rpc_options, ) } fn streamthrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::StreamthrowsStreamError>>, crate::errors::pub_sub_streaming_service::StreamthrowsError>> { >>::as_ref(self).streamthrows_with_rpc_opts( arg_foo, rpc_options, ) } fn servicethrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ServicethrowsStreamError>>, crate::errors::pub_sub_streaming_service::ServicethrowsError>> { >>::as_ref(self).servicethrows_with_rpc_opts( arg_foo, rpc_options, ) } fn servicethrows2_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::Servicethrows2StreamError>>, crate::errors::pub_sub_streaming_service::Servicethrows2Error>> { >>::as_ref(self).servicethrows2_with_rpc_opts( arg_foo, rpc_options, ) } fn boththrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::BoththrowsStreamError>>, crate::errors::pub_sub_streaming_service::BoththrowsError>> { >>::as_ref(self).boththrows_with_rpc_opts( arg_foo, rpc_options, ) } fn responseandstreamstreamthrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError>> { >>::as_ref(self).responseandstreamstreamthrows_with_rpc_opts( arg_foo, rpc_options, ) } fn responseandstreamservicethrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError>> { >>::as_ref(self).responseandstreamservicethrows_with_rpc_opts( arg_foo, rpc_options, ) } fn responseandstreamboththrows_with_rpc_opts( &self, arg_foo: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<(::std::primitive::i32, ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsStreamError>>), crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError>> { >>::as_ref(self).responseandstreamboththrows_with_rpc_opts( arg_foo, rpc_options, ) } fn returnstreamFast_with_rpc_opts( &self, arg_i32_from: ::std::primitive::i32, arg_i32_to: ::std::primitive::i32, rpc_options: T::RpcOptions, ) -> ::futures::future::BoxFuture<'static, ::std::result::Result<::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::errors::pub_sub_streaming_service::ReturnstreamFastStreamError>>, crate::errors::pub_sub_streaming_service::ReturnstreamFastError>> { >>::as_ref(self).returnstreamFast_with_rpc_opts( arg_i32_from, arg_i32_to, rpc_options, ) } fn transport(&self) -> &T { as PubSubStreamingServiceExt>::transport(>>::as_ref(self)) } } #[derive(Clone)] pub struct make_PubSubStreamingService; /// To be called by user directly setting up a client. Avoids /// needing ClientFactory trait in scope, avoids unidiomatic /// make_Trait name. /// /// ``` /// # const _: &str = stringify! { /// use bgs::client::BuckGraphService; /// /// let protocol = BinaryProtocol::new(); /// let transport = HttpClient::new(); /// let client = ::new(protocol, transport); /// # }; /// ``` impl dyn PubSubStreamingService { pub fn new( protocol: P, transport: T, ) -> ::std::sync::Arc where P: ::fbthrift::Protocol, T: ::fbthrift::Transport, P::Deserializer: ::std::marker::Send, { let spawner = ::fbthrift::help::NoopSpawner; Self::with_spawner(protocol, transport, spawner) } pub fn with_spawner( protocol: P, transport: T, spawner: S, ) -> ::std::sync::Arc where P: ::fbthrift::Protocol, T: ::fbthrift::Transport, P::Deserializer: ::std::marker::Send, S: ::fbthrift::help::Spawner, { let _ = protocol; let _ = spawner; ::std::sync::Arc::new(PubSubStreamingServiceImpl::::new(transport)) } } impl dyn PubSubStreamingServiceExt where T: ::fbthrift::Transport, { pub fn new

( protocol: P, transport: T, ) -> ::std::sync::Arc + ::std::marker::Send + ::std::marker::Sync + 'static> where P: ::fbthrift::Protocol, P::Deserializer: ::std::marker::Send, { let spawner = ::fbthrift::help::NoopSpawner; Self::with_spawner(protocol, transport, spawner) } pub fn with_spawner( protocol: P, transport: T, spawner: S, ) -> ::std::sync::Arc + ::std::marker::Send + ::std::marker::Sync + 'static> where P: ::fbthrift::Protocol, P::Deserializer: ::std::marker::Send, S: ::fbthrift::help::Spawner, { let _ = protocol; let _ = spawner; ::std::sync::Arc::new(PubSubStreamingServiceImpl::::new(transport)) } } pub type PubSubStreamingServiceDynClient = ::Api; pub type PubSubStreamingServiceClient = ::std::sync::Arc; /// The same thing, but to be called from generic contexts where we are /// working with a type parameter `C: ClientFactory` to produce clients. impl ::fbthrift::ClientFactory for make_PubSubStreamingService { type Api = dyn PubSubStreamingService + ::std::marker::Send + ::std::marker::Sync + 'static; fn with_spawner(protocol: P, transport: T, spawner: S) -> ::std::sync::Arc where P: ::fbthrift::Protocol, T: ::fbthrift::Transport, P::Deserializer: ::std::marker::Send, S: ::fbthrift::help::Spawner, { ::with_spawner(protocol, transport, spawner) } }