pub fn de_completion_payload(
body: &mut ::aws_smithy_types::body::SdkBody,
) -> std::result::Result<
crate::event_receiver::EventReceiver<crate::types::ResponseStream, crate::types::error::ResponseStreamError>,
crate::operation::invoke_agent::InvokeAgentError,
> {
let unmarshaller = crate::event_stream_serde::ResponseStreamUnmarshaller::new();
let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
Ok(receiver)
}
pub(crate) fn de_content_type_header(
header_map: &::aws_smithy_runtime_api::http::Headers,
) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
let headers = header_map.get_all("x-amzn-bedrock-agent-content-type");
::aws_smithy_http::header::one_or_none(headers)
}
pub(crate) fn de_memory_id_header(
header_map: &::aws_smithy_runtime_api::http::Headers,
) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
let headers = header_map.get_all("x-amz-bedrock-agent-memory-id");
::aws_smithy_http::header::one_or_none(headers)
}
pub(crate) fn de_session_id_header(
header_map: &::aws_smithy_runtime_api::http::Headers,
) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
let headers = header_map.get_all("x-amz-bedrock-agent-session-id");
::aws_smithy_http::header::one_or_none(headers)
}