in crates/amzn-qdeveloper-streaming-client/src/event_stream_serde.rs [15:131]
fn unmarshall(
&self,
message: &::aws_smithy_types::event_stream::Message,
) -> std::result::Result<
::aws_smithy_eventstream::frame::UnmarshalledMessage<Self::Output, Self::Error>,
::aws_smithy_eventstream::error::Error,
> {
let response_headers = ::aws_smithy_eventstream::smithy::parse_response_headers(message)?;
match response_headers.message_type.as_str() {
"event" => match response_headers.smithy_type.as_str() {
"codeEvent" => {
let parsed = crate::protocol_serde::shape_code_event::de_code_event_payload(&message.payload()[..])
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!(
"failed to unmarshall CodeEvent: {}",
err
))
})?;
Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
crate::types::GenerateCodeFromCommandsResponseStream::CodeEvent(parsed),
))
},
_unknown_variant => Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
crate::types::GenerateCodeFromCommandsResponseStream::Unknown,
)),
},
"exception" => {
let generic = match crate::protocol_serde::parse_event_stream_error_metadata(message.payload()) {
Ok(builder) => builder.build(),
Err(err) => {
return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
crate::types::error::GenerateCodeFromCommandsResponseStreamError::unhandled(err),
));
},
};
match response_headers.smithy_type.as_str() {
"Error" => {
let mut builder = crate::types::error::builders::InternalServerErrorBuilder::default();
builder =
crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(
&message.payload()[..],
builder,
)
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!(
"failed to unmarshall Error: {}",
err
))
})?;
builder.set_meta(Some(generic));
return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
crate::types::error::GenerateCodeFromCommandsResponseStreamError::InternalServerError(
crate::serde_util::internal_server_error_correct_errors(builder)
.build()
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!("{}", err))
})?,
),
));
},
"QuotaLevelExceededError" => {
let mut builder = crate::types::error::builders::ServiceQuotaExceededErrorBuilder::default();
builder = crate::protocol_serde::shape_service_quota_exceeded_error::de_service_quota_exceeded_error_json_err(
&message.payload()[..],
builder,
)
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!("failed to unmarshall QuotaLevelExceededError: {}", err))
})?;
builder.set_meta(Some(generic));
return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
crate::types::error::GenerateCodeFromCommandsResponseStreamError::ServiceQuotaExceededError(
crate::serde_util::service_quota_exceeded_error_correct_errors(builder)
.build()
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!("{}", err))
})?,
),
));
},
"ValidationError" => {
let mut builder = crate::types::error::builders::ValidationErrorBuilder::default();
builder = crate::protocol_serde::shape_validation_error::de_validation_error_json_err(
&message.payload()[..],
builder,
)
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!(
"failed to unmarshall ValidationError: {}",
err
))
})?;
builder.set_meta(Some(generic));
return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
crate::types::error::GenerateCodeFromCommandsResponseStreamError::ValidationError(
crate::serde_util::validation_error_correct_errors(builder)
.build()
.map_err(|err| {
::aws_smithy_eventstream::error::Error::unmarshalling(format!("{}", err))
})?,
),
));
},
_ => {},
}
Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
crate::types::error::GenerateCodeFromCommandsResponseStreamError::generic(generic),
))
},
value => {
return Err(::aws_smithy_eventstream::error::Error::unmarshalling(format!(
"unrecognized :message-type: {}",
value
)));
},
}
}