Client Test

Client Test

rev. 4086b1854579bc6eae24dce129090ceaa6b97f5e

Files changed:

tmp-codegen-diff/codegen-client-test/Cargo.lock

@@ -369,369 +429,429 @@
  389    389   
 "jemallocator",
  390    390   
 "mimalloc",
  391    391   
]
  392    392   
  393    393   
[[package]]
  394    394   
name = "aws-smithy-experimental"
  395    395   
version = "0.2.1"
  396    396   
  397    397   
[[package]]
  398    398   
name = "aws-smithy-http"
  399         -
version = "0.62.5"
         399  +
version = "0.62.6"
  400    400   
dependencies = [
  401    401   
 "async-stream",
  402    402   
 "aws-smithy-eventstream",
  403    403   
 "aws-smithy-runtime-api",
  404    404   
 "aws-smithy-types",
  405    405   
 "bytes",
  406    406   
 "bytes-utils",
  407    407   
 "futures-core",
  408    408   
 "futures-util",
  409    409   
 "http 0.2.12",
@@ -512,512 +572,572 @@
  532    532   
name = "aws-smithy-json"
  533    533   
version = "0.61.7"
  534    534   
dependencies = [
  535    535   
 "aws-smithy-types",
  536    536   
 "proptest",
  537    537   
 "serde_json",
  538    538   
]
  539    539   
  540    540   
[[package]]
  541    541   
name = "aws-smithy-mocks"
  542         -
version = "0.2.0"
         542  +
version = "0.2.1"
  543    543   
dependencies = [
  544    544   
 "aws-smithy-async",
  545    545   
 "aws-smithy-http-client",
  546    546   
 "aws-smithy-runtime",
  547    547   
 "aws-smithy-runtime-api",
  548    548   
 "aws-smithy-types",
  549    549   
 "http 1.3.1",
  550    550   
 "tokio",
  551    551   
]
  552    552

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/protocol_serde/shape_capture_pokemon_output.rs

@@ -1,1 +14,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn de_events_payload(
    3      3   
    body: &mut ::aws_smithy_types::body::SdkBody,
    4      4   
) -> std::result::Result<
    5      5   
    crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
    6      6   
    crate::operation::capture_pokemon::CapturePokemonError,
    7      7   
> {
    8      8   
    let unmarshaller = crate::event_stream_serde::CapturePokemonEventsUnmarshaller::new();
    9      9   
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
   10         -
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
   11         -
        unmarshaller,
   12         -
        body,
   13         -
    )))
          10  +
    let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
          11  +
    Ok(receiver)
   14     12   
}

tmp-codegen-diff/codegen-client-test/pokemon-service-client/rust-client-codegen/src/protocol_serde/shape_capture_pokemon_output.rs

@@ -1,1 +14,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn de_events_payload(
    3      3   
    body: &mut ::aws_smithy_types::body::SdkBody,
    4      4   
) -> std::result::Result<
    5      5   
    crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
    6      6   
    crate::operation::capture_pokemon::CapturePokemonError,
    7      7   
> {
    8      8   
    let unmarshaller = crate::event_stream_serde::CapturePokemonEventsUnmarshaller::new();
    9      9   
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
   10         -
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
   11         -
        unmarshaller,
   12         -
        body,
   13         -
    )))
          10  +
    let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
          11  +
    Ok(receiver)
   14     12   
}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/src/protocol_serde/shape_streaming_operation_output.rs

@@ -1,1 +14,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn de_events_payload(
    3      3   
    body: &mut ::aws_smithy_types::body::SdkBody,
    4      4   
) -> std::result::Result<
    5      5   
    crate::event_receiver::EventReceiver<crate::types::Events, crate::types::error::EventsError>,
    6      6   
    crate::operation::streaming_operation::StreamingOperationError,
    7      7   
> {
    8      8   
    let unmarshaller = crate::event_stream_serde::EventsUnmarshaller::new();
    9      9   
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
   10         -
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
   11         -
        unmarshaller,
   12         -
        body,
   13         -
    )))
          10  +
    let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
          11  +
    Ok(receiver)
   14     12   
}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/src/protocol_serde/shape_streaming_operation_with_initial_data_output.rs

@@ -1,1 +14,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn de_events_payload(
    3      3   
    body: &mut ::aws_smithy_types::body::SdkBody,
    4      4   
) -> std::result::Result<
    5      5   
    crate::event_receiver::EventReceiver<crate::types::Events, crate::types::error::EventsError>,
    6      6   
    crate::operation::streaming_operation_with_initial_data::StreamingOperationWithInitialDataError,
    7      7   
> {
    8      8   
    let unmarshaller = crate::event_stream_serde::EventsUnmarshaller::new();
    9      9   
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
   10         -
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
   11         -
        unmarshaller,
   12         -
        body,
   13         -
    )))
          10  +
    let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
          11  +
    Ok(receiver)
   14     12   
}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/src/protocol_serde/shape_streaming_operation_with_initial_response_output.rs

@@ -1,1 +14,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn de_events_payload(
    3      3   
    body: &mut ::aws_smithy_types::body::SdkBody,
    4      4   
) -> std::result::Result<
    5      5   
    crate::event_receiver::EventReceiver<crate::types::Events, crate::types::error::EventsError>,
    6      6   
    crate::operation::streaming_operation_with_initial_response::StreamingOperationWithInitialResponseError,
    7      7   
> {
    8      8   
    let unmarshaller = crate::event_stream_serde::EventsUnmarshaller::new();
    9      9   
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
   10         -
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
   11         -
        unmarshaller,
   12         -
        body,
   13         -
    )))
          10  +
    let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
          11  +
    Ok(receiver)
   14     12   
}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/src/protocol_serde/shape_streaming_operation_with_optional_data_output.rs

@@ -1,1 +14,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn de_events_payload(
    3      3   
    body: &mut ::aws_smithy_types::body::SdkBody,
    4      4   
) -> std::result::Result<
    5      5   
    crate::event_receiver::EventReceiver<crate::types::Events, crate::types::error::EventsError>,
    6      6   
    crate::operation::streaming_operation_with_optional_data::StreamingOperationWithOptionalDataError,
    7      7   
> {
    8      8   
    let unmarshaller = crate::event_stream_serde::EventsUnmarshaller::new();
    9      9   
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
   10         -
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
   11         -
        unmarshaller,
   12         -
        body,
   13         -
    )))
          10  +
    let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
          11  +
    Ok(receiver)
   14     12   
}