// @generated by Thrift for thrift/compiler/test/fixtures/stream/src/module.thrift
// This file is probably not the place you want to edit!
//! Thrift service definitions for `module`.
/// Service definitions for `PubSubStreamingService`.
pub mod pub_sub_streaming_service {
#[derive(Clone, Debug)]
pub enum ReturnstreamStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ReturnstreamStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ReturnstreamStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ReturnstreamStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ReturnstreamStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ReturnstreamStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Returnstream");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ReturnstreamStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ReturnstreamStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ReturnstreamStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum ReturnstreamResponseExn {
#[doc(hidden)]
Success(()),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ReturnstreamResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ReturnstreamResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ReturnstreamResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ReturnstreamResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Void;
}
impl ::fbthrift::Serialize
for ReturnstreamResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Returnstream");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::Void,
0i16,
);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ReturnstreamResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = Self::Success(());
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::Void, 0i32), false) => {
once = true;
alt = Self::Success(::fbthrift::Deserialize::read(p)?);
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ReturnstreamResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
::std::result::Result::Ok(alt)
}
}
pub enum ReturnstreamExn {
#[doc(hidden)]
Success( ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::ReturnstreamStreamExn>>
),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for ReturnstreamExn {
fn from(err: crate::errors::pub_sub_streaming_service::ReturnstreamError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::ReturnstreamError::ApplicationException(aexn) => ReturnstreamExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::ReturnstreamError::ThriftError(err) => ReturnstreamExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ReturnstreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for ReturnstreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ReturnstreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::fbthrift::GetTType for ReturnstreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum StreamthrowsStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
e(crate::types::FooStreamEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for StreamthrowsStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for StreamthrowsStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for StreamthrowsStreamExn {
fn from(exn: crate::types::FooStreamEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for StreamthrowsStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for StreamthrowsStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for StreamthrowsStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Streamthrows");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for StreamthrowsStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = ::std::option::Option::Some(Self::e(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"StreamthrowsStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "StreamthrowsStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum StreamthrowsResponseExn {
#[doc(hidden)]
Success(()),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for StreamthrowsResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for StreamthrowsResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for StreamthrowsResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for StreamthrowsResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Void;
}
impl ::fbthrift::Serialize
for StreamthrowsResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Streamthrows");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::Void,
0i16,
);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for StreamthrowsResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = Self::Success(());
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::Void, 0i32), false) => {
once = true;
alt = Self::Success(::fbthrift::Deserialize::read(p)?);
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"StreamthrowsResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
::std::result::Result::Ok(alt)
}
}
pub enum StreamthrowsExn {
#[doc(hidden)]
Success( ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::StreamthrowsStreamExn>>
),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for StreamthrowsExn {
fn from(err: crate::errors::pub_sub_streaming_service::StreamthrowsError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::StreamthrowsError::ApplicationException(aexn) => StreamthrowsExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::StreamthrowsError::ThriftError(err) => StreamthrowsExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for StreamthrowsExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for StreamthrowsExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for StreamthrowsExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::fbthrift::GetTType for StreamthrowsExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum ServicethrowsStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ServicethrowsStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ServicethrowsStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ServicethrowsStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ServicethrowsStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ServicethrowsStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Servicethrows");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ServicethrowsStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ServicethrowsStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ServicethrowsStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum ServicethrowsResponseExn {
#[doc(hidden)]
Success(()),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ServicethrowsResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ServicethrowsResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for ServicethrowsResponseExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ServicethrowsResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ServicethrowsResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Void;
}
impl ::fbthrift::Serialize
for ServicethrowsResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Servicethrows");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::Void,
0i16,
);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ServicethrowsResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = Self::Success(());
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::Void, 0i32), false) => {
once = true;
alt = Self::Success(::fbthrift::Deserialize::read(p)?);
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = Self::e(::fbthrift::Deserialize::read(p)?);
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ServicethrowsResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
::std::result::Result::Ok(alt)
}
}
pub enum ServicethrowsExn {
#[doc(hidden)]
Success( ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::ServicethrowsStreamExn>>
),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for ServicethrowsExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From for ServicethrowsExn {
fn from(err: crate::errors::pub_sub_streaming_service::ServicethrowsError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::ServicethrowsError::e(err) => ServicethrowsExn::e(err),
crate::errors::pub_sub_streaming_service::ServicethrowsError::ApplicationException(aexn) => ServicethrowsExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::ServicethrowsError::ThriftError(err) => ServicethrowsExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ServicethrowsExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for ServicethrowsExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ServicethrowsExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::fbthrift::GetTType for ServicethrowsExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum Servicethrows2StreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for Servicethrows2StreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for Servicethrows2StreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for Servicethrows2StreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for Servicethrows2StreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for Servicethrows2StreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Servicethrows2");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for Servicethrows2StreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e1", ::fbthrift::TType::Struct, 1),
::fbthrift::Field::new("e2", ::fbthrift::TType::Struct, 2),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"Servicethrows2StreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "Servicethrows2StreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum Servicethrows2ResponseExn {
#[doc(hidden)]
Success(()),
e1(crate::types::FooEx), e2(crate::types::FooEx2),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for Servicethrows2ResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e1(exn) => exn.exn_name(),
Self::e2(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e1(exn) => exn.exn_value(),
Self::e2(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e1(exn) => exn.exn_is_declared(),
Self::e2(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for Servicethrows2ResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e1(_exn) => fbthrift::ResultType::Error,
Self::e2(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for Servicethrows2ResponseExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e1(exn)
}
} impl ::std::convert::From for Servicethrows2ResponseExn {
fn from(exn: crate::types::FooEx2) -> Self {
Self::e2(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for Servicethrows2ResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for Servicethrows2ResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Void;
}
impl ::fbthrift::Serialize
for Servicethrows2ResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Servicethrows2");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::Void,
0i16,
);
p.write_field_end();
}
Self::e1(inner) => {
p.write_field_begin(
"e1",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::e2(inner) => {
p.write_field_begin(
"e2",
::fbthrift::TType::Struct,
2,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for Servicethrows2ResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e1", ::fbthrift::TType::Struct, 1),
::fbthrift::Field::new("e2", ::fbthrift::TType::Struct, 2),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = Self::Success(());
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::Void, 0i32), false) => {
once = true;
alt = Self::Success(::fbthrift::Deserialize::read(p)?);
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = Self::e1(::fbthrift::Deserialize::read(p)?);
}
((::fbthrift::TType::Struct, 2), false) => {
once = true;
alt = Self::e2(::fbthrift::Deserialize::read(p)?);
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"Servicethrows2ResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
::std::result::Result::Ok(alt)
}
}
pub enum Servicethrows2Exn {
#[doc(hidden)]
Success( ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::Servicethrows2StreamExn>>
),
e1(crate::types::FooEx),
e2(crate::types::FooEx2),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for Servicethrows2Exn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e1(exn)
}
}
impl ::std::convert::From for Servicethrows2Exn {
fn from(exn: crate::types::FooEx2) -> Self {
Self::e2(exn)
}
}
impl ::std::convert::From for Servicethrows2Exn {
fn from(err: crate::errors::pub_sub_streaming_service::Servicethrows2Error) -> Self {
match err {
crate::errors::pub_sub_streaming_service::Servicethrows2Error::e1(err) => Servicethrows2Exn::e1(err),
crate::errors::pub_sub_streaming_service::Servicethrows2Error::e2(err) => Servicethrows2Exn::e2(err),
crate::errors::pub_sub_streaming_service::Servicethrows2Error::ApplicationException(aexn) => Servicethrows2Exn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::Servicethrows2Error::ThriftError(err) => Servicethrows2Exn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for Servicethrows2Exn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for Servicethrows2Exn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e1(exn) => exn.exn_name(),
Self::e2(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e1(exn) => exn.exn_value(),
Self::e2(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e1(exn) => exn.exn_is_declared(),
Self::e2(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for Servicethrows2Exn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e1(_exn) => fbthrift::ResultType::Error,
Self::e2(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::fbthrift::GetTType for Servicethrows2Exn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum BoththrowsStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
e(crate::types::FooStreamEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for BoththrowsStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for BoththrowsStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for BoththrowsStreamExn {
fn from(exn: crate::types::FooStreamEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for BoththrowsStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for BoththrowsStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for BoththrowsStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Boththrows");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for BoththrowsStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = ::std::option::Option::Some(Self::e(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"BoththrowsStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "BoththrowsStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum BoththrowsResponseExn {
#[doc(hidden)]
Success(()),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for BoththrowsResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for BoththrowsResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for BoththrowsResponseExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for BoththrowsResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for BoththrowsResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Void;
}
impl ::fbthrift::Serialize
for BoththrowsResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Boththrows");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::Void,
0i16,
);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for BoththrowsResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = Self::Success(());
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::Void, 0i32), false) => {
once = true;
alt = Self::Success(::fbthrift::Deserialize::read(p)?);
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = Self::e(::fbthrift::Deserialize::read(p)?);
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"BoththrowsResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
::std::result::Result::Ok(alt)
}
}
pub enum BoththrowsExn {
#[doc(hidden)]
Success( ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::BoththrowsStreamExn>>
),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for BoththrowsExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From for BoththrowsExn {
fn from(err: crate::errors::pub_sub_streaming_service::BoththrowsError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::BoththrowsError::e(err) => BoththrowsExn::e(err),
crate::errors::pub_sub_streaming_service::BoththrowsError::ApplicationException(aexn) => BoththrowsExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::BoththrowsError::ThriftError(err) => BoththrowsExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for BoththrowsExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for BoththrowsExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for BoththrowsExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::fbthrift::GetTType for BoththrowsExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum ResponseandstreamstreamthrowsStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
e(crate::types::FooStreamEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamstreamthrowsStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamstreamthrowsStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for ResponseandstreamstreamthrowsStreamExn {
fn from(exn: crate::types::FooStreamEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamstreamthrowsStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ResponseandstreamstreamthrowsStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ResponseandstreamstreamthrowsStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Responseandstreamstreamthrows");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ResponseandstreamstreamthrowsStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = ::std::option::Option::Some(Self::e(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ResponseandstreamstreamthrowsStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ResponseandstreamstreamthrowsStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum ResponseandstreamstreamthrowsResponseExn {
#[doc(hidden)]
Success(::std::primitive::i32),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamstreamthrowsResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamstreamthrowsResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamstreamthrowsResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ResponseandstreamstreamthrowsResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ResponseandstreamstreamthrowsResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Responseandstreamstreamthrows");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
_inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ResponseandstreamstreamthrowsResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ResponseandstreamstreamthrowsResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ResponseandstreamstreamthrowsResponseExn"),
)
.into(),
)
}
}
pub enum ResponseandstreamstreamthrowsExn {
#[doc(hidden)]
Success((
::std::primitive::i32,
::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::ResponseandstreamstreamthrowsStreamExn>>
)
),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for ResponseandstreamstreamthrowsExn {
fn from(err: crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError::ApplicationException(aexn) => ResponseandstreamstreamthrowsExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::ResponseandstreamstreamthrowsError::ThriftError(err) => ResponseandstreamstreamthrowsExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamstreamthrowsExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamstreamthrowsExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamstreamthrowsExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::fbthrift::GetTType for ResponseandstreamstreamthrowsExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum ResponseandstreamservicethrowsStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamservicethrowsStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamservicethrowsStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamservicethrowsStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ResponseandstreamservicethrowsStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ResponseandstreamservicethrowsStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Responseandstreamservicethrows");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ResponseandstreamservicethrowsStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ResponseandstreamservicethrowsStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ResponseandstreamservicethrowsStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum ResponseandstreamservicethrowsResponseExn {
#[doc(hidden)]
Success(::std::primitive::i32),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamservicethrowsResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamservicethrowsResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for ResponseandstreamservicethrowsResponseExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamservicethrowsResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ResponseandstreamservicethrowsResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ResponseandstreamservicethrowsResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Responseandstreamservicethrows");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
_inner.write(p);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ResponseandstreamservicethrowsResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = ::std::option::Option::Some(Self::e(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ResponseandstreamservicethrowsResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ResponseandstreamservicethrowsResponseExn"),
)
.into(),
)
}
}
pub enum ResponseandstreamservicethrowsExn {
#[doc(hidden)]
Success((
::std::primitive::i32,
::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::ResponseandstreamservicethrowsStreamExn>>
)
),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for ResponseandstreamservicethrowsExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From for ResponseandstreamservicethrowsExn {
fn from(err: crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError::e(err) => ResponseandstreamservicethrowsExn::e(err),
crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError::ApplicationException(aexn) => ResponseandstreamservicethrowsExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::ResponseandstreamservicethrowsError::ThriftError(err) => ResponseandstreamservicethrowsExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamservicethrowsExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamservicethrowsExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamservicethrowsExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::fbthrift::GetTType for ResponseandstreamservicethrowsExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum ResponseandstreamboththrowsStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
e(crate::types::FooStreamEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamboththrowsStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamboththrowsStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for ResponseandstreamboththrowsStreamExn {
fn from(exn: crate::types::FooStreamEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamboththrowsStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ResponseandstreamboththrowsStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ResponseandstreamboththrowsStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Responseandstreamboththrows");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ResponseandstreamboththrowsStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = ::std::option::Option::Some(Self::e(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ResponseandstreamboththrowsStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ResponseandstreamboththrowsStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum ResponseandstreamboththrowsResponseExn {
#[doc(hidden)]
Success(::std::primitive::i32),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamboththrowsResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamboththrowsResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::std::convert::From for ResponseandstreamboththrowsResponseExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamboththrowsResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ResponseandstreamboththrowsResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ResponseandstreamboththrowsResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("Responseandstreamboththrows");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
_inner.write(p);
p.write_field_end();
}
Self::e(inner) => {
p.write_field_begin(
"e",
::fbthrift::TType::Struct,
1,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ResponseandstreamboththrowsResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
::fbthrift::Field::new("e", ::fbthrift::TType::Struct, 1),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((::fbthrift::TType::Struct, 1), false) => {
once = true;
alt = ::std::option::Option::Some(Self::e(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ResponseandstreamboththrowsResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ResponseandstreamboththrowsResponseExn"),
)
.into(),
)
}
}
pub enum ResponseandstreamboththrowsExn {
#[doc(hidden)]
Success((
::std::primitive::i32,
::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::ResponseandstreamboththrowsStreamExn>>
)
),
e(crate::types::FooEx),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for ResponseandstreamboththrowsExn {
fn from(exn: crate::types::FooEx) -> Self {
Self::e(exn)
}
}
impl ::std::convert::From for ResponseandstreamboththrowsExn {
fn from(err: crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError::e(err) => ResponseandstreamboththrowsExn::e(err),
crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError::ApplicationException(aexn) => ResponseandstreamboththrowsExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::ResponseandstreamboththrowsError::ThriftError(err) => ResponseandstreamboththrowsExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ResponseandstreamboththrowsExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for ResponseandstreamboththrowsExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
Self::e(exn) => exn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
Self::e(exn) => exn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
Self::e(exn) => exn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ResponseandstreamboththrowsExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
Self::e(_exn) => fbthrift::ResultType::Error,
}
}
}
impl ::fbthrift::GetTType for ResponseandstreamboththrowsExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
#[derive(Clone, Debug)]
pub enum ReturnstreamFastStreamExn {
#[doc(hidden)]
Success(::std::primitive::i32),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ReturnstreamFastStreamExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ReturnstreamFastStreamExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ReturnstreamFastStreamExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ReturnstreamFastStreamExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
impl ::fbthrift::Serialize
for ReturnstreamFastStreamExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("ReturnstreamFast");
match self {
Self::Success(inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::I32,
0i16,
);
inner.write(p);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ReturnstreamFastStreamExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = ::std::option::Option::None;
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::I32, 0i32), false) => {
once = true;
alt = ::std::option::Option::Some(Self::Success(::fbthrift::Deserialize::read(p)?));
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ReturnstreamFastStreamExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
alt.ok_or_else(||
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::MissingResult,
format!("Empty union {}", "ReturnstreamFastStreamExn"),
)
.into(),
)
}
}
#[derive(Clone, Debug)]
pub enum ReturnstreamFastResponseExn {
#[doc(hidden)]
Success(()),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::fbthrift::ExceptionInfo for ReturnstreamFastResponseExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ReturnstreamFastResponseExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ReturnstreamFastResponseExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::GetTType for ReturnstreamFastResponseExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Void;
}
impl ::fbthrift::Serialize
for ReturnstreamFastResponseExn
where
P: ::fbthrift::ProtocolWriter,
{
fn write(&self, p: &mut P) {
if let Self::ApplicationException(aexn) = self {
return aexn.write(p);
}
p.write_struct_begin("ReturnstreamFast");
match self {
Self::Success(_inner) => {
p.write_field_begin(
"Success",
::fbthrift::TType::Void,
0i16,
);
p.write_field_end();
}
Self::ApplicationException(_) => unreachable!(),
}
p.write_field_stop();
p.write_struct_end();
}
}
impl
::fbthrift::Deserialize
for ReturnstreamFastResponseExn
where
P: ::fbthrift::ProtocolReader,
{
fn read(p: &mut P) -> ::anyhow::Result {
static RETURNS: &[::fbthrift::Field] = &[
::fbthrift::Field::new("Success", ::fbthrift::TType::Stream, 0),
];
let _ = p.read_struct_begin(|_| ())?;
let mut once = false;
let mut alt = Self::Success(());
loop {
let (_, fty, fid) = p.read_field_begin(|_| (), RETURNS)?;
match ((fty, fid as ::std::primitive::i32), once) {
((::fbthrift::TType::Stop, _), _) => {
p.read_field_end()?;
break;
}
((::fbthrift::TType::Void, 0i32), false) => {
once = true;
alt = Self::Success(::fbthrift::Deserialize::read(p)?);
}
((ty, _id), false) => p.skip(ty)?,
((badty, badid), true) => return ::std::result::Result::Err(::std::convert::From::from(
::fbthrift::ApplicationException::new(
::fbthrift::ApplicationExceptionErrorCode::ProtocolError,
format!(
"unwanted extra union {} field ty {:?} id {}",
"ReturnstreamFastResponseExn",
badty,
badid,
),
)
)),
}
p.read_field_end()?;
}
p.read_struct_end()?;
::std::result::Result::Ok(alt)
}
}
pub enum ReturnstreamFastExn {
#[doc(hidden)]
Success( ::futures::stream::BoxStream<'static, ::std::result::Result<::std::primitive::i32, crate::services::pub_sub_streaming_service::ReturnstreamFastStreamExn>>
),
ApplicationException(::fbthrift::ApplicationException),
}
impl ::std::convert::From for ReturnstreamFastExn {
fn from(err: crate::errors::pub_sub_streaming_service::ReturnstreamFastError) -> Self {
match err {
crate::errors::pub_sub_streaming_service::ReturnstreamFastError::ApplicationException(aexn) => ReturnstreamFastExn::ApplicationException(aexn),
crate::errors::pub_sub_streaming_service::ReturnstreamFastError::ThriftError(err) => ReturnstreamFastExn::ApplicationException(::fbthrift::ApplicationException {
message: err.to_string(),
type_: ::fbthrift::ApplicationExceptionErrorCode::InternalError,
}),
}
}
}
impl ::std::convert::From<::fbthrift::ApplicationException> for ReturnstreamFastExn {
fn from(exn: ::fbthrift::ApplicationException) -> Self {
Self::ApplicationException(exn)
}
}
impl ::fbthrift::ExceptionInfo for ReturnstreamFastExn {
fn exn_name(&self) -> &'static str {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_name called on Success"),
Self::ApplicationException(aexn) => aexn.exn_name(),
}
}
fn exn_value(&self) -> String {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_value called on Success"),
Self::ApplicationException(aexn) => aexn.exn_value(),
}
}
fn exn_is_declared(&self) -> bool {
match self {
Self::Success(_) => panic!("ExceptionInfo::exn_is_declared called on Success"),
Self::ApplicationException(aexn) => aexn.exn_is_declared(),
}
}
}
impl ::fbthrift::ResultInfo for ReturnstreamFastExn {
fn result_type(&self) -> ::fbthrift::ResultType {
match self {
Self::Success(_) => ::fbthrift::ResultType::Return,
Self::ApplicationException(_aexn) => ::fbthrift::ResultType::Exception,
}
}
}
impl ::fbthrift::GetTType for ReturnstreamFastExn {
const TTYPE: ::fbthrift::TType = ::fbthrift::TType::Struct;
}
}