AWS SDK

AWS SDK

rev. 96f5a1b4ad139d2f1ad1e8e40f300e1cd1ff574c

Files changed:

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/_transcript_result_stream.rs

@@ -9,9 +0,95 @@
   29     29   
    }
   30     30   
    /// Returns true if this is a [`TranscriptEvent`](crate::types::TranscriptResultStream::TranscriptEvent).
   31     31   
    pub fn is_transcript_event(&self) -> bool {
   32     32   
        self.as_transcript_event().is_ok()
   33     33   
    }
   34     34   
    /// Returns true if the enum instance is the `Unknown` variant.
   35     35   
    pub fn is_unknown(&self) -> bool {
   36     36   
        matches!(self, Self::Unknown)
   37     37   
    }
   38     38   
}
          39  +
static TRANSCRIPTRESULTSTREAM_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
          40  +
    "com.amazonaws.transcribestreaming#TranscriptResultStream",
          41  +
    "com.amazonaws.transcribestreaming",
          42  +
    "TranscriptResultStream",
          43  +
);
          44  +
static TRANSCRIPTRESULTSTREAM_MEMBER_TRANSCRIPTEVENT: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
          45  +
    ::aws_smithy_schema::ShapeId::from_static(
          46  +
        "com.amazonaws.transcribestreaming#TranscriptResultStream$TranscriptEvent",
          47  +
        "com.amazonaws.transcribestreaming",
          48  +
        "TranscriptResultStream",
          49  +
    ),
          50  +
    ::aws_smithy_schema::ShapeType::Structure,
          51  +
    "TranscriptEvent",
          52  +
    0,
          53  +
);
          54  +
static TRANSCRIPTRESULTSTREAM_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
          55  +
    TRANSCRIPTRESULTSTREAM_SCHEMA_ID,
          56  +
    ::aws_smithy_schema::ShapeType::Union,
          57  +
    &[&TRANSCRIPTRESULTSTREAM_MEMBER_TRANSCRIPTEVENT],
          58  +
)
          59  +
.with_streaming();
          60  +
impl TranscriptResultStream {
          61  +
    /// The schema for this shape.
          62  +
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &TRANSCRIPTRESULTSTREAM_SCHEMA;
          63  +
}
          64  +
impl ::aws_smithy_schema::serde::SerializableStruct for TranscriptResultStream {
          65  +
    #[allow(unused_variables, clippy::diverging_sub_expression)]
          66  +
    fn serialize_members(
          67  +
        &self,
          68  +
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
          69  +
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
          70  +
        match self {
          71  +
            Self::TranscriptEvent(val) => {
          72  +
                ser.write_struct(&TRANSCRIPTRESULTSTREAM_MEMBER_TRANSCRIPTEVENT, val)?;
          73  +
            }
          74  +
            Self::Unknown => return Err(::aws_smithy_schema::serde::SerdeError::custom("cannot serialize unknown union variant")),
          75  +
        }
          76  +
        Ok(())
          77  +
    }
          78  +
}
          79  +
impl TranscriptResultStream {
          80  +
    /// Deserializes this union from a [`ShapeDeserializer`].
          81  +
    pub fn deserialize(
          82  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          83  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          84  +
        let mut result: ::std::option::Option<Self> = ::std::option::Option::None;
          85  +
        #[allow(unused_variables, unreachable_code, clippy::single_match, clippy::match_single_binding)]
          86  +
        deserializer.read_struct(&TRANSCRIPTRESULTSTREAM_SCHEMA, &mut |member, deser| {
          87  +
            result = ::std::option::Option::Some(match member.member_index() {
          88  +
                Some(0) => Self::TranscriptEvent(crate::types::TranscriptEvent::deserialize(deser)?),
          89  +
                _ => Self::Unknown,
          90  +
            });
          91  +
            Ok(())
          92  +
        })?;
          93  +
        result.ok_or_else(|| ::aws_smithy_schema::serde::SerdeError::custom("expected a union variant"))
          94  +
    }
          95  +
}

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/_utterance_event.rs

@@ -72,72 +242,242 @@
   92     92   
    "com.amazonaws.transcribestreaming",
   93     93   
    "UtteranceEvent",
   94     94   
);
   95     95   
static UTTERANCEEVENT_MEMBER_UTTERANCE_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   96     96   
    ::aws_smithy_schema::ShapeId::from_static(
   97     97   
        "com.amazonaws.transcribestreaming#UtteranceEvent$UtteranceId",
   98     98   
        "com.amazonaws.transcribestreaming",
   99     99   
        "UtteranceEvent",
  100    100   
    ),
  101    101   
    ::aws_smithy_schema::ShapeType::String,
  102         -
    "utterance_id",
         102  +
    "UtteranceId",
  103    103   
    0,
  104    104   
);
  105    105   
static UTTERANCEEVENT_MEMBER_IS_PARTIAL: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  106    106   
    ::aws_smithy_schema::ShapeId::from_static(
  107    107   
        "com.amazonaws.transcribestreaming#UtteranceEvent$IsPartial",
  108    108   
        "com.amazonaws.transcribestreaming",
  109    109   
        "UtteranceEvent",
  110    110   
    ),
  111    111   
    ::aws_smithy_schema::ShapeType::Boolean,
  112         -
    "is_partial",
         112  +
    "IsPartial",
  113    113   
    1,
  114    114   
);
  115    115   
static UTTERANCEEVENT_MEMBER_PARTICIPANT_ROLE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  116    116   
    ::aws_smithy_schema::ShapeId::from_static(
  117    117   
        "com.amazonaws.transcribestreaming#UtteranceEvent$ParticipantRole",
  118    118   
        "com.amazonaws.transcribestreaming",
  119    119   
        "UtteranceEvent",
  120    120   
    ),
  121    121   
    ::aws_smithy_schema::ShapeType::String,
  122         -
    "participant_role",
         122  +
    "ParticipantRole",
  123    123   
    2,
  124    124   
);
  125    125   
static UTTERANCEEVENT_MEMBER_BEGIN_OFFSET_MILLIS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  126    126   
    ::aws_smithy_schema::ShapeId::from_static(
  127    127   
        "com.amazonaws.transcribestreaming#UtteranceEvent$BeginOffsetMillis",
  128    128   
        "com.amazonaws.transcribestreaming",
  129    129   
        "UtteranceEvent",
  130    130   
    ),
  131    131   
    ::aws_smithy_schema::ShapeType::Long,
  132         -
    "begin_offset_millis",
         132  +
    "BeginOffsetMillis",
  133    133   
    3,
  134    134   
);
  135    135   
static UTTERANCEEVENT_MEMBER_END_OFFSET_MILLIS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  136    136   
    ::aws_smithy_schema::ShapeId::from_static(
  137    137   
        "com.amazonaws.transcribestreaming#UtteranceEvent$EndOffsetMillis",
  138    138   
        "com.amazonaws.transcribestreaming",
  139    139   
        "UtteranceEvent",
  140    140   
    ),
  141    141   
    ::aws_smithy_schema::ShapeType::Long,
  142         -
    "end_offset_millis",
         142  +
    "EndOffsetMillis",
  143    143   
    4,
  144    144   
);
  145    145   
static UTTERANCEEVENT_MEMBER_TRANSCRIPT: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  146    146   
    ::aws_smithy_schema::ShapeId::from_static(
  147    147   
        "com.amazonaws.transcribestreaming#UtteranceEvent$Transcript",
  148    148   
        "com.amazonaws.transcribestreaming",
  149    149   
        "UtteranceEvent",
  150    150   
    ),
  151    151   
    ::aws_smithy_schema::ShapeType::String,
  152         -
    "transcript",
         152  +
    "Transcript",
  153    153   
    5,
  154    154   
);
  155    155   
static UTTERANCEEVENT_MEMBER_ITEMS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  156    156   
    ::aws_smithy_schema::ShapeId::from_static(
  157    157   
        "com.amazonaws.transcribestreaming#UtteranceEvent$Items",
  158    158   
        "com.amazonaws.transcribestreaming",
  159    159   
        "UtteranceEvent",
  160    160   
    ),
  161    161   
    ::aws_smithy_schema::ShapeType::List,
  162         -
    "items",
         162  +
    "Items",
  163    163   
    6,
  164    164   
);
  165    165   
static UTTERANCEEVENT_MEMBER_ENTITIES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  166    166   
    ::aws_smithy_schema::ShapeId::from_static(
  167    167   
        "com.amazonaws.transcribestreaming#UtteranceEvent$Entities",
  168    168   
        "com.amazonaws.transcribestreaming",
  169    169   
        "UtteranceEvent",
  170    170   
    ),
  171    171   
    ::aws_smithy_schema::ShapeType::List,
  172         -
    "entities",
         172  +
    "Entities",
  173    173   
    7,
  174    174   
);
  175    175   
static UTTERANCEEVENT_MEMBER_SENTIMENT: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  176    176   
    ::aws_smithy_schema::ShapeId::from_static(
  177    177   
        "com.amazonaws.transcribestreaming#UtteranceEvent$Sentiment",
  178    178   
        "com.amazonaws.transcribestreaming",
  179    179   
        "UtteranceEvent",
  180    180   
    ),
  181    181   
    ::aws_smithy_schema::ShapeType::String,
  182         -
    "sentiment",
         182  +
    "Sentiment",
  183    183   
    8,
  184    184   
);
  185    185   
static UTTERANCEEVENT_MEMBER_ISSUES_DETECTED: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  186    186   
    ::aws_smithy_schema::ShapeId::from_static(
  187    187   
        "com.amazonaws.transcribestreaming#UtteranceEvent$IssuesDetected",
  188    188   
        "com.amazonaws.transcribestreaming",
  189    189   
        "UtteranceEvent",
  190    190   
    ),
  191    191   
    ::aws_smithy_schema::ShapeType::List,
  192         -
    "issues_detected",
         192  +
    "IssuesDetected",
  193    193   
    9,
  194    194   
);
  195    195   
static UTTERANCEEVENT_MEMBER_LANGUAGE_CODE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  196    196   
    ::aws_smithy_schema::ShapeId::from_static(
  197    197   
        "com.amazonaws.transcribestreaming#UtteranceEvent$LanguageCode",
  198    198   
        "com.amazonaws.transcribestreaming",
  199    199   
        "UtteranceEvent",
  200    200   
    ),
  201    201   
    ::aws_smithy_schema::ShapeType::String,
  202         -
    "language_code",
         202  +
    "LanguageCode",
  203    203   
    10,
  204    204   
);
  205    205   
static UTTERANCEEVENT_MEMBER_LANGUAGE_IDENTIFICATION: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
  206    206   
    ::aws_smithy_schema::ShapeId::from_static(
  207    207   
        "com.amazonaws.transcribestreaming#UtteranceEvent$LanguageIdentification",
  208    208   
        "com.amazonaws.transcribestreaming",
  209    209   
        "UtteranceEvent",
  210    210   
    ),
  211    211   
    ::aws_smithy_schema::ShapeType::List,
  212         -
    "language_identification",
         212  +
    "LanguageIdentification",
  213    213   
    11,
  214    214   
);
  215    215   
static UTTERANCEEVENT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
  216    216   
    UTTERANCEEVENT_SCHEMA_ID,
  217    217   
    ::aws_smithy_schema::ShapeType::Structure,
  218    218   
    &[
  219    219   
        &UTTERANCEEVENT_MEMBER_UTTERANCE_ID,
  220    220   
        &UTTERANCEEVENT_MEMBER_IS_PARTIAL,
  221    221   
        &UTTERANCEEVENT_MEMBER_PARTICIPANT_ROLE,
  222    222   
        &UTTERANCEEVENT_MEMBER_BEGIN_OFFSET_MILLIS,
@@ -287,287 +443,442 @@
  307    307   
                    }
  308    308   
                    Ok(())
  309    309   
                },
  310    310   
            )?;
  311    311   
        }
  312    312   
        Ok(())
  313    313   
    }
  314    314   
}
  315    315   
impl UtteranceEvent {
  316    316   
    /// Deserializes this structure from a [`ShapeDeserializer`].
  317         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
  318         -
        deserializer: &mut D,
         317  +
    pub fn deserialize(
         318  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
  319    319   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
  320    320   
        #[allow(unused_variables, unused_mut)]
  321    321   
        let mut builder = Self::builder();
  322    322   
        #[allow(
  323    323   
            unused_variables,
  324    324   
            unreachable_code,
  325    325   
            clippy::single_match,
  326    326   
            clippy::match_single_binding,
  327    327   
            clippy::diverging_sub_expression
  328    328   
        )]
  329         -
        deserializer.read_struct(&UTTERANCEEVENT_SCHEMA, (), |_, member, deser| {
         329  +
        deserializer.read_struct(&UTTERANCEEVENT_SCHEMA, &mut |member, deser| {
  330    330   
            match member.member_index() {
  331    331   
                Some(0) => {
  332    332   
                    builder.utterance_id = Some(deser.read_string(member)?);
  333    333   
                }
  334    334   
                Some(1) => {
  335    335   
                    builder.is_partial = Some(deser.read_boolean(member)?);
  336    336   
                }
  337    337   
                Some(2) => {
  338    338   
                    builder.participant_role = Some(crate::types::ParticipantRole::from(deser.read_string(member)?.as_str()));
  339    339   
                }
  340    340   
                Some(3) => {
  341    341   
                    builder.begin_offset_millis = Some(deser.read_long(member)?);
  342    342   
                }
  343    343   
                Some(4) => {
  344    344   
                    builder.end_offset_millis = Some(deser.read_long(member)?);
  345    345   
                }
  346    346   
                Some(5) => {
  347    347   
                    builder.transcript = Some(deser.read_string(member)?);
  348    348   
                }
  349    349   
                Some(6) => {
  350    350   
                    builder.items = Some({
  351         -
                        let container = if let Some(cap) = deser.container_size() {
  352         -
                            Vec::with_capacity(cap)
  353         -
                        } else {
  354         -
                            Vec::new()
  355         -
                        };
  356         -
                        deser.read_list(member, container, |mut list, deser| {
  357         -
                            list.push(crate::types::CallAnalyticsItem::deserialize(deser)?);
  358         -
                            Ok(list)
  359         -
                        })?
         351  +
                        let mut container = Vec::new();
         352  +
                        deser.read_list(member, &mut |deser| {
         353  +
                            container.push(crate::types::CallAnalyticsItem::deserialize(deser)?);
         354  +
                            Ok(())
         355  +
                        })?;
         356  +
                        container
  360    357   
                    });
  361    358   
                }
  362    359   
                Some(7) => {
  363    360   
                    builder.entities = Some({
  364         -
                        let container = if let Some(cap) = deser.container_size() {
  365         -
                            Vec::with_capacity(cap)
  366         -
                        } else {
  367         -
                            Vec::new()
  368         -
                        };
  369         -
                        deser.read_list(member, container, |mut list, deser| {
  370         -
                            list.push(crate::types::CallAnalyticsEntity::deserialize(deser)?);
  371         -
                            Ok(list)
  372         -
                        })?
         361  +
                        let mut container = Vec::new();
         362  +
                        deser.read_list(member, &mut |deser| {
         363  +
                            container.push(crate::types::CallAnalyticsEntity::deserialize(deser)?);
         364  +
                            Ok(())
         365  +
                        })?;
         366  +
                        container
  373    367   
                    });
  374    368   
                }
  375    369   
                Some(8) => {
  376    370   
                    builder.sentiment = Some(crate::types::Sentiment::from(deser.read_string(member)?.as_str()));
  377    371   
                }
  378    372   
                Some(9) => {
  379    373   
                    builder.issues_detected = Some({
  380         -
                        let container = if let Some(cap) = deser.container_size() {
  381         -
                            Vec::with_capacity(cap)
  382         -
                        } else {
  383         -
                            Vec::new()
  384         -
                        };
  385         -
                        deser.read_list(member, container, |mut list, deser| {
  386         -
                            list.push(crate::types::IssueDetected::deserialize(deser)?);
  387         -
                            Ok(list)
  388         -
                        })?
         374  +
                        let mut container = Vec::new();
         375  +
                        deser.read_list(member, &mut |deser| {
         376  +
                            container.push(crate::types::IssueDetected::deserialize(deser)?);
         377  +
                            Ok(())
         378  +
                        })?;
         379  +
                        container
  389    380   
                    });
  390    381   
                }
  391    382   
                Some(10) => {
  392    383   
                    builder.language_code = Some(crate::types::CallAnalyticsLanguageCode::from(deser.read_string(member)?.as_str()));
  393    384   
                }
  394    385   
                Some(11) => {
  395    386   
                    builder.language_identification = Some({
  396         -
                        let container = if let Some(cap) = deser.container_size() {
  397         -
                            Vec::with_capacity(cap)
  398         -
                        } else {
  399         -
                            Vec::new()
  400         -
                        };
  401         -
                        deser.read_list(member, container, |mut list, deser| {
  402         -
                            list.push(crate::types::CallAnalyticsLanguageWithScore::deserialize(deser)?);
  403         -
                            Ok(list)
  404         -
                        })?
         387  +
                        let mut container = Vec::new();
         388  +
                        deser.read_list(member, &mut |deser| {
         389  +
                            container.push(crate::types::CallAnalyticsLanguageWithScore::deserialize(deser)?);
         390  +
                            Ok(())
         391  +
                        })?;
         392  +
                        container
  405    393   
                    });
  406    394   
                }
  407    395   
                _ => {}
  408    396   
            }
  409    397   
            Ok(())
  410    398   
        })?;
  411    399   
        Ok(builder.build())
  412    400   
    }
  413    401   
}
         402  +
impl UtteranceEvent {
         403  +
    /// Deserializes this structure from a body deserializer and HTTP response.
         404  +
    pub fn deserialize_with_response(
         405  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
         406  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
         407  +
        _status: u16,
         408  +
        _body: &[u8],
         409  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         410  +
        Self::deserialize(deserializer)
         411  +
    }
         412  +
}
  414    413   
impl UtteranceEvent {
  415    414   
    /// Creates a new builder-style object to manufacture [`UtteranceEvent`](crate::types::UtteranceEvent).
  416    415   
    pub fn builder() -> crate::types::builders::UtteranceEventBuilder {
  417    416   
        crate::types::builders::UtteranceEventBuilder::default()
  418    417   
    }
  419    418   
}
  420    419   
  421    420   
/// A builder for [`UtteranceEvent`](crate::types::UtteranceEvent).
  422    421   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
  423    422   
#[non_exhaustive]

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/error/_bad_request_exception.rs

@@ -1,1 +102,113 @@
   13     13   
    "com.amazonaws.transcribestreaming",
   14     14   
    "BadRequestException",
   15     15   
);
   16     16   
static BADREQUESTEXCEPTION_MEMBER_MESSAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   17     17   
    ::aws_smithy_schema::ShapeId::from_static(
   18     18   
        "com.amazonaws.transcribestreaming#BadRequestException$Message",
   19     19   
        "com.amazonaws.transcribestreaming",
   20     20   
        "BadRequestException",
   21     21   
    ),
   22     22   
    ::aws_smithy_schema::ShapeType::String,
   23         -
    "message",
          23  +
    "Message",
   24     24   
    0,
   25     25   
);
   26     26   
static BADREQUESTEXCEPTION_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
   27     27   
    BADREQUESTEXCEPTION_SCHEMA_ID,
   28     28   
    ::aws_smithy_schema::ShapeType::Structure,
   29     29   
    &[&BADREQUESTEXCEPTION_MEMBER_MESSAGE],
   30     30   
);
   31     31   
impl BadRequestException {
   32     32   
    /// The schema for this shape.
   33     33   
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &BADREQUESTEXCEPTION_SCHEMA;
   34     34   
}
   35     35   
impl ::aws_smithy_schema::serde::SerializableStruct for BadRequestException {
   36     36   
    #[allow(unused_variables, clippy::diverging_sub_expression)]
   37     37   
    fn serialize_members(
   38     38   
        &self,
   39     39   
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
   40     40   
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
   41     41   
        if let Some(ref val) = self.message {
   42     42   
            ser.write_string(&BADREQUESTEXCEPTION_MEMBER_MESSAGE, val)?;
   43     43   
        }
   44     44   
        Ok(())
   45     45   
    }
   46     46   
}
   47     47   
impl BadRequestException {
   48     48   
    /// Deserializes this structure from a [`ShapeDeserializer`].
   49         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
   50         -
        deserializer: &mut D,
          49  +
    pub fn deserialize(
          50  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
   51     51   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
   52     52   
        #[allow(unused_variables, unused_mut)]
   53     53   
        let mut builder = Self::builder();
   54     54   
        #[allow(
   55     55   
            unused_variables,
   56     56   
            unreachable_code,
   57     57   
            clippy::single_match,
   58     58   
            clippy::match_single_binding,
   59     59   
            clippy::diverging_sub_expression
   60     60   
        )]
   61         -
        deserializer.read_struct(&BADREQUESTEXCEPTION_SCHEMA, (), |_, member, deser| {
          61  +
        deserializer.read_struct(&BADREQUESTEXCEPTION_SCHEMA, &mut |member, deser| {
   62     62   
            match member.member_index() {
   63     63   
                Some(0) => {
   64     64   
                    builder.message = Some(deser.read_string(member)?);
   65     65   
                }
   66     66   
                _ => {}
   67     67   
            }
   68     68   
            Ok(())
   69     69   
        })?;
   70     70   
        Ok(builder.build())
   71     71   
    }
   72     72   
}
          73  +
impl BadRequestException {
          74  +
    /// Deserializes this structure from a body deserializer and HTTP response.
          75  +
    pub fn deserialize_with_response(
          76  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          77  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
          78  +
        _status: u16,
          79  +
        _body: &[u8],
          80  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          81  +
        Self::deserialize(deserializer)
          82  +
    }
          83  +
}
   73     84   
impl BadRequestException {
   74     85   
    /// Returns the error message.
   75     86   
    pub fn message(&self) -> ::std::option::Option<&str> {
   76     87   
        self.message.as_deref()
   77     88   
    }
   78     89   
}
   79     90   
impl ::std::fmt::Display for BadRequestException {
   80     91   
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
   81     92   
        ::std::write!(f, "BadRequestException")?;
   82     93   
        if let ::std::option::Option::Some(inner_1) = &self.message {

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/error/_conflict_exception.rs

@@ -1,1 +102,113 @@
   13     13   
    "com.amazonaws.transcribestreaming",
   14     14   
    "ConflictException",
   15     15   
);
   16     16   
static CONFLICTEXCEPTION_MEMBER_MESSAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   17     17   
    ::aws_smithy_schema::ShapeId::from_static(
   18     18   
        "com.amazonaws.transcribestreaming#ConflictException$Message",
   19     19   
        "com.amazonaws.transcribestreaming",
   20     20   
        "ConflictException",
   21     21   
    ),
   22     22   
    ::aws_smithy_schema::ShapeType::String,
   23         -
    "message",
          23  +
    "Message",
   24     24   
    0,
   25     25   
);
   26     26   
static CONFLICTEXCEPTION_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
   27     27   
    CONFLICTEXCEPTION_SCHEMA_ID,
   28     28   
    ::aws_smithy_schema::ShapeType::Structure,
   29     29   
    &[&CONFLICTEXCEPTION_MEMBER_MESSAGE],
   30     30   
);
   31     31   
impl ConflictException {
   32     32   
    /// The schema for this shape.
   33     33   
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &CONFLICTEXCEPTION_SCHEMA;
   34     34   
}
   35     35   
impl ::aws_smithy_schema::serde::SerializableStruct for ConflictException {
   36     36   
    #[allow(unused_variables, clippy::diverging_sub_expression)]
   37     37   
    fn serialize_members(
   38     38   
        &self,
   39     39   
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
   40     40   
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
   41     41   
        if let Some(ref val) = self.message {
   42     42   
            ser.write_string(&CONFLICTEXCEPTION_MEMBER_MESSAGE, val)?;
   43     43   
        }
   44     44   
        Ok(())
   45     45   
    }
   46     46   
}
   47     47   
impl ConflictException {
   48     48   
    /// Deserializes this structure from a [`ShapeDeserializer`].
   49         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
   50         -
        deserializer: &mut D,
          49  +
    pub fn deserialize(
          50  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
   51     51   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
   52     52   
        #[allow(unused_variables, unused_mut)]
   53     53   
        let mut builder = Self::builder();
   54     54   
        #[allow(
   55     55   
            unused_variables,
   56     56   
            unreachable_code,
   57     57   
            clippy::single_match,
   58     58   
            clippy::match_single_binding,
   59     59   
            clippy::diverging_sub_expression
   60     60   
        )]
   61         -
        deserializer.read_struct(&CONFLICTEXCEPTION_SCHEMA, (), |_, member, deser| {
          61  +
        deserializer.read_struct(&CONFLICTEXCEPTION_SCHEMA, &mut |member, deser| {
   62     62   
            match member.member_index() {
   63     63   
                Some(0) => {
   64     64   
                    builder.message = Some(deser.read_string(member)?);
   65     65   
                }
   66     66   
                _ => {}
   67     67   
            }
   68     68   
            Ok(())
   69     69   
        })?;
   70     70   
        Ok(builder.build())
   71     71   
    }
   72     72   
}
          73  +
impl ConflictException {
          74  +
    /// Deserializes this structure from a body deserializer and HTTP response.
          75  +
    pub fn deserialize_with_response(
          76  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          77  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
          78  +
        _status: u16,
          79  +
        _body: &[u8],
          80  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          81  +
        Self::deserialize(deserializer)
          82  +
    }
          83  +
}
   73     84   
impl ConflictException {
   74     85   
    /// Returns the error message.
   75     86   
    pub fn message(&self) -> ::std::option::Option<&str> {
   76     87   
        self.message.as_deref()
   77     88   
    }
   78     89   
}
   79     90   
impl ::std::fmt::Display for ConflictException {
   80     91   
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
   81     92   
        ::std::write!(f, "ConflictException")?;
   82     93   
        if let ::std::option::Option::Some(inner_1) = &self.message {

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/error/_internal_failure_exception.rs

@@ -1,1 +102,113 @@
   13     13   
    "com.amazonaws.transcribestreaming",
   14     14   
    "InternalFailureException",
   15     15   
);
   16     16   
static INTERNALFAILUREEXCEPTION_MEMBER_MESSAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   17     17   
    ::aws_smithy_schema::ShapeId::from_static(
   18     18   
        "com.amazonaws.transcribestreaming#InternalFailureException$Message",
   19     19   
        "com.amazonaws.transcribestreaming",
   20     20   
        "InternalFailureException",
   21     21   
    ),
   22     22   
    ::aws_smithy_schema::ShapeType::String,
   23         -
    "message",
          23  +
    "Message",
   24     24   
    0,
   25     25   
);
   26     26   
static INTERNALFAILUREEXCEPTION_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
   27     27   
    INTERNALFAILUREEXCEPTION_SCHEMA_ID,
   28     28   
    ::aws_smithy_schema::ShapeType::Structure,
   29     29   
    &[&INTERNALFAILUREEXCEPTION_MEMBER_MESSAGE],
   30     30   
);
   31     31   
impl InternalFailureException {
   32     32   
    /// The schema for this shape.
   33     33   
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &INTERNALFAILUREEXCEPTION_SCHEMA;
   34     34   
}
   35     35   
impl ::aws_smithy_schema::serde::SerializableStruct for InternalFailureException {
   36     36   
    #[allow(unused_variables, clippy::diverging_sub_expression)]
   37     37   
    fn serialize_members(
   38     38   
        &self,
   39     39   
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
   40     40   
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
   41     41   
        if let Some(ref val) = self.message {
   42     42   
            ser.write_string(&INTERNALFAILUREEXCEPTION_MEMBER_MESSAGE, val)?;
   43     43   
        }
   44     44   
        Ok(())
   45     45   
    }
   46     46   
}
   47     47   
impl InternalFailureException {
   48     48   
    /// Deserializes this structure from a [`ShapeDeserializer`].
   49         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
   50         -
        deserializer: &mut D,
          49  +
    pub fn deserialize(
          50  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
   51     51   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
   52     52   
        #[allow(unused_variables, unused_mut)]
   53     53   
        let mut builder = Self::builder();
   54     54   
        #[allow(
   55     55   
            unused_variables,
   56     56   
            unreachable_code,
   57     57   
            clippy::single_match,
   58     58   
            clippy::match_single_binding,
   59     59   
            clippy::diverging_sub_expression
   60     60   
        )]
   61         -
        deserializer.read_struct(&INTERNALFAILUREEXCEPTION_SCHEMA, (), |_, member, deser| {
          61  +
        deserializer.read_struct(&INTERNALFAILUREEXCEPTION_SCHEMA, &mut |member, deser| {
   62     62   
            match member.member_index() {
   63     63   
                Some(0) => {
   64     64   
                    builder.message = Some(deser.read_string(member)?);
   65     65   
                }
   66     66   
                _ => {}
   67     67   
            }
   68     68   
            Ok(())
   69     69   
        })?;
   70     70   
        Ok(builder.build())
   71     71   
    }
   72     72   
}
          73  +
impl InternalFailureException {
          74  +
    /// Deserializes this structure from a body deserializer and HTTP response.
          75  +
    pub fn deserialize_with_response(
          76  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          77  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
          78  +
        _status: u16,
          79  +
        _body: &[u8],
          80  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          81  +
        Self::deserialize(deserializer)
          82  +
    }
          83  +
}
   73     84   
impl InternalFailureException {
   74     85   
    /// Returns the error message.
   75     86   
    pub fn message(&self) -> ::std::option::Option<&str> {
   76     87   
        self.message.as_deref()
   77     88   
    }
   78     89   
}
   79     90   
impl ::std::fmt::Display for InternalFailureException {
   80     91   
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
   81     92   
        ::std::write!(f, "InternalFailureException")?;
   82     93   
        if let ::std::option::Option::Some(inner_1) = &self.message {

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/error/_limit_exceeded_exception.rs

@@ -1,1 +102,113 @@
   13     13   
    "com.amazonaws.transcribestreaming",
   14     14   
    "LimitExceededException",
   15     15   
);
   16     16   
static LIMITEXCEEDEDEXCEPTION_MEMBER_MESSAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   17     17   
    ::aws_smithy_schema::ShapeId::from_static(
   18     18   
        "com.amazonaws.transcribestreaming#LimitExceededException$Message",
   19     19   
        "com.amazonaws.transcribestreaming",
   20     20   
        "LimitExceededException",
   21     21   
    ),
   22     22   
    ::aws_smithy_schema::ShapeType::String,
   23         -
    "message",
          23  +
    "Message",
   24     24   
    0,
   25     25   
);
   26     26   
static LIMITEXCEEDEDEXCEPTION_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
   27     27   
    LIMITEXCEEDEDEXCEPTION_SCHEMA_ID,
   28     28   
    ::aws_smithy_schema::ShapeType::Structure,
   29     29   
    &[&LIMITEXCEEDEDEXCEPTION_MEMBER_MESSAGE],
   30     30   
);
   31     31   
impl LimitExceededException {
   32     32   
    /// The schema for this shape.
   33     33   
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &LIMITEXCEEDEDEXCEPTION_SCHEMA;
   34     34   
}
   35     35   
impl ::aws_smithy_schema::serde::SerializableStruct for LimitExceededException {
   36     36   
    #[allow(unused_variables, clippy::diverging_sub_expression)]
   37     37   
    fn serialize_members(
   38     38   
        &self,
   39     39   
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
   40     40   
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
   41     41   
        if let Some(ref val) = self.message {
   42     42   
            ser.write_string(&LIMITEXCEEDEDEXCEPTION_MEMBER_MESSAGE, val)?;
   43     43   
        }
   44     44   
        Ok(())
   45     45   
    }
   46     46   
}
   47     47   
impl LimitExceededException {
   48     48   
    /// Deserializes this structure from a [`ShapeDeserializer`].
   49         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
   50         -
        deserializer: &mut D,
          49  +
    pub fn deserialize(
          50  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
   51     51   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
   52     52   
        #[allow(unused_variables, unused_mut)]
   53     53   
        let mut builder = Self::builder();
   54     54   
        #[allow(
   55     55   
            unused_variables,
   56     56   
            unreachable_code,
   57     57   
            clippy::single_match,
   58     58   
            clippy::match_single_binding,
   59     59   
            clippy::diverging_sub_expression
   60     60   
        )]
   61         -
        deserializer.read_struct(&LIMITEXCEEDEDEXCEPTION_SCHEMA, (), |_, member, deser| {
          61  +
        deserializer.read_struct(&LIMITEXCEEDEDEXCEPTION_SCHEMA, &mut |member, deser| {
   62     62   
            match member.member_index() {
   63     63   
                Some(0) => {
   64     64   
                    builder.message = Some(deser.read_string(member)?);
   65     65   
                }
   66     66   
                _ => {}
   67     67   
            }
   68     68   
            Ok(())
   69     69   
        })?;
   70     70   
        Ok(builder.build())
   71     71   
    }
   72     72   
}
          73  +
impl LimitExceededException {
          74  +
    /// Deserializes this structure from a body deserializer and HTTP response.
          75  +
    pub fn deserialize_with_response(
          76  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          77  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
          78  +
        _status: u16,
          79  +
        _body: &[u8],
          80  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          81  +
        Self::deserialize(deserializer)
          82  +
    }
          83  +
}
   73     84   
impl LimitExceededException {
   74     85   
    /// Returns the error message.
   75     86   
    pub fn message(&self) -> ::std::option::Option<&str> {
   76     87   
        self.message.as_deref()
   77     88   
    }
   78     89   
}
   79     90   
impl ::std::fmt::Display for LimitExceededException {
   80     91   
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
   81     92   
        ::std::write!(f, "LimitExceededException")?;
   82     93   
        if let ::std::option::Option::Some(inner_1) = &self.message {

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/error/_resource_not_found_exception.rs

@@ -1,1 +102,113 @@
   13     13   
    "com.amazonaws.transcribestreaming",
   14     14   
    "ResourceNotFoundException",
   15     15   
);
   16     16   
static RESOURCENOTFOUNDEXCEPTION_MEMBER_MESSAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   17     17   
    ::aws_smithy_schema::ShapeId::from_static(
   18     18   
        "com.amazonaws.transcribestreaming#ResourceNotFoundException$Message",
   19     19   
        "com.amazonaws.transcribestreaming",
   20     20   
        "ResourceNotFoundException",
   21     21   
    ),
   22     22   
    ::aws_smithy_schema::ShapeType::String,
   23         -
    "message",
          23  +
    "Message",
   24     24   
    0,
   25     25   
);
   26     26   
static RESOURCENOTFOUNDEXCEPTION_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
   27     27   
    RESOURCENOTFOUNDEXCEPTION_SCHEMA_ID,
   28     28   
    ::aws_smithy_schema::ShapeType::Structure,
   29     29   
    &[&RESOURCENOTFOUNDEXCEPTION_MEMBER_MESSAGE],
   30     30   
);
   31     31   
impl ResourceNotFoundException {
   32     32   
    /// The schema for this shape.
   33     33   
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &RESOURCENOTFOUNDEXCEPTION_SCHEMA;
   34     34   
}
   35     35   
impl ::aws_smithy_schema::serde::SerializableStruct for ResourceNotFoundException {
   36     36   
    #[allow(unused_variables, clippy::diverging_sub_expression)]
   37     37   
    fn serialize_members(
   38     38   
        &self,
   39     39   
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
   40     40   
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
   41     41   
        if let Some(ref val) = self.message {
   42     42   
            ser.write_string(&RESOURCENOTFOUNDEXCEPTION_MEMBER_MESSAGE, val)?;
   43     43   
        }
   44     44   
        Ok(())
   45     45   
    }
   46     46   
}
   47     47   
impl ResourceNotFoundException {
   48     48   
    /// Deserializes this structure from a [`ShapeDeserializer`].
   49         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
   50         -
        deserializer: &mut D,
          49  +
    pub fn deserialize(
          50  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
   51     51   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
   52     52   
        #[allow(unused_variables, unused_mut)]
   53     53   
        let mut builder = Self::builder();
   54     54   
        #[allow(
   55     55   
            unused_variables,
   56     56   
            unreachable_code,
   57     57   
            clippy::single_match,
   58     58   
            clippy::match_single_binding,
   59     59   
            clippy::diverging_sub_expression
   60     60   
        )]
   61         -
        deserializer.read_struct(&RESOURCENOTFOUNDEXCEPTION_SCHEMA, (), |_, member, deser| {
          61  +
        deserializer.read_struct(&RESOURCENOTFOUNDEXCEPTION_SCHEMA, &mut |member, deser| {
   62     62   
            match member.member_index() {
   63     63   
                Some(0) => {
   64     64   
                    builder.message = Some(deser.read_string(member)?);
   65     65   
                }
   66     66   
                _ => {}
   67     67   
            }
   68     68   
            Ok(())
   69     69   
        })?;
   70     70   
        Ok(builder.build())
   71     71   
    }
   72     72   
}
          73  +
impl ResourceNotFoundException {
          74  +
    /// Deserializes this structure from a body deserializer and HTTP response.
          75  +
    pub fn deserialize_with_response(
          76  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          77  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
          78  +
        _status: u16,
          79  +
        _body: &[u8],
          80  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          81  +
        Self::deserialize(deserializer)
          82  +
    }
          83  +
}
   73     84   
impl ResourceNotFoundException {
   74     85   
    /// Returns the error message.
   75     86   
    pub fn message(&self) -> ::std::option::Option<&str> {
   76     87   
        self.message.as_deref()
   77     88   
    }
   78     89   
}
   79     90   
impl ::std::fmt::Display for ResourceNotFoundException {
   80     91   
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
   81     92   
        ::std::write!(f, "ResourceNotFoundException")?;
   82     93   
        if let ::std::option::Option::Some(inner_1) = &self.message {

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/types/error/_service_unavailable_exception.rs

@@ -1,1 +102,113 @@
   13     13   
    "com.amazonaws.transcribestreaming",
   14     14   
    "ServiceUnavailableException",
   15     15   
);
   16     16   
static SERVICEUNAVAILABLEEXCEPTION_MEMBER_MESSAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
   17     17   
    ::aws_smithy_schema::ShapeId::from_static(
   18     18   
        "com.amazonaws.transcribestreaming#ServiceUnavailableException$Message",
   19     19   
        "com.amazonaws.transcribestreaming",
   20     20   
        "ServiceUnavailableException",
   21     21   
    ),
   22     22   
    ::aws_smithy_schema::ShapeType::String,
   23         -
    "message",
          23  +
    "Message",
   24     24   
    0,
   25     25   
);
   26     26   
static SERVICEUNAVAILABLEEXCEPTION_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
   27     27   
    SERVICEUNAVAILABLEEXCEPTION_SCHEMA_ID,
   28     28   
    ::aws_smithy_schema::ShapeType::Structure,
   29     29   
    &[&SERVICEUNAVAILABLEEXCEPTION_MEMBER_MESSAGE],
   30     30   
);
   31     31   
impl ServiceUnavailableException {
   32     32   
    /// The schema for this shape.
   33     33   
    pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &SERVICEUNAVAILABLEEXCEPTION_SCHEMA;
   34     34   
}
   35     35   
impl ::aws_smithy_schema::serde::SerializableStruct for ServiceUnavailableException {
   36     36   
    #[allow(unused_variables, clippy::diverging_sub_expression)]
   37     37   
    fn serialize_members(
   38     38   
        &self,
   39     39   
        ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
   40     40   
    ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
   41     41   
        if let Some(ref val) = self.message {
   42     42   
            ser.write_string(&SERVICEUNAVAILABLEEXCEPTION_MEMBER_MESSAGE, val)?;
   43     43   
        }
   44     44   
        Ok(())
   45     45   
    }
   46     46   
}
   47     47   
impl ServiceUnavailableException {
   48     48   
    /// Deserializes this structure from a [`ShapeDeserializer`].
   49         -
    pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
   50         -
        deserializer: &mut D,
          49  +
    pub fn deserialize(
          50  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
   51     51   
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
   52     52   
        #[allow(unused_variables, unused_mut)]
   53     53   
        let mut builder = Self::builder();
   54     54   
        #[allow(
   55     55   
            unused_variables,
   56     56   
            unreachable_code,
   57     57   
            clippy::single_match,
   58     58   
            clippy::match_single_binding,
   59     59   
            clippy::diverging_sub_expression
   60     60   
        )]
   61         -
        deserializer.read_struct(&SERVICEUNAVAILABLEEXCEPTION_SCHEMA, (), |_, member, deser| {
          61  +
        deserializer.read_struct(&SERVICEUNAVAILABLEEXCEPTION_SCHEMA, &mut |member, deser| {
   62     62   
            match member.member_index() {
   63     63   
                Some(0) => {
   64     64   
                    builder.message = Some(deser.read_string(member)?);
   65     65   
                }
   66     66   
                _ => {}
   67     67   
            }
   68     68   
            Ok(())
   69     69   
        })?;
   70     70   
        Ok(builder.build())
   71     71   
    }
   72     72   
}
          73  +
impl ServiceUnavailableException {
          74  +
    /// Deserializes this structure from a body deserializer and HTTP response.
          75  +
    pub fn deserialize_with_response(
          76  +
        deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
          77  +
        _headers: &::aws_smithy_runtime_api::http::Headers,
          78  +
        _status: u16,
          79  +
        _body: &[u8],
          80  +
    ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
          81  +
        Self::deserialize(deserializer)
          82  +
    }
          83  +
}
   73     84   
impl ServiceUnavailableException {
   74     85   
    /// Returns the error message.
   75     86   
    pub fn message(&self) -> ::std::option::Option<&str> {
   76     87   
        self.message.as_deref()
   77     88   
    }
   78     89   
}
   79     90   
impl ::std::fmt::Display for ServiceUnavailableException {
   80     91   
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
   81     92   
        ::std::write!(f, "ServiceUnavailableException")?;
   82     93   
        if let ::std::option::Option::Some(inner_1) = &self.message {

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/tests/canary_repro.rs

@@ -0,1 +0,126 @@
           1  +
/*
           2  +
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
           3  +
 * SPDX-License-Identifier: Apache-2.0
           4  +
 */
           5  +
           6  +
//! Verifies that the schema-based serialization path (via SdkConfig →
           7  +
//! SharedClientProtocol) produces correct requests for streaming operations.
           8  +
           9  +
use async_stream::stream;
          10  +
use aws_credential_types::Credentials;
          11  +
use aws_sdk_transcribestreaming::config::Region;
          12  +
use aws_sdk_transcribestreaming::primitives::Blob;
          13  +
use aws_sdk_transcribestreaming::types::{
          14  +
    AudioEvent, AudioStream, LanguageCode, MediaEncoding, TranscriptResultStream,
          15  +
};
          16  +
use aws_sdk_transcribestreaming::Client;
          17  +
use aws_smithy_http_client::test_util::dvr::{Event, ReplayingClient};
          18  +
use bytes::BufMut;
          19  +
          20  +
const CHUNK_SIZE: usize = 8192;
          21  +
          22  +
fn client_from_sdk_config(replayer: ReplayingClient) -> Client {
          23  +
    let sdk_config =
          24  +
        aws_types::SdkConfig::builder()
          25  +
            .region(Region::from_static("us-west-2"))
          26  +
            .credentials_provider(
          27  +
                aws_credential_types::provider::SharedCredentialsProvider::new(
          28  +
                    Credentials::for_tests(),
          29  +
                ),
          30  +
            )
          31  +
            .http_client(replayer)
          32  +
            .build();
          33  +
    Client::new(&sdk_config)
          34  +
}
          35  +
          36  +
async fn run_transcribe(client: &Client) -> Result<String, Box<dyn std::error::Error>> {
          37  +
    let input_stream = stream! {
          38  +
        let pcm = pcm_data();
          39  +
        for chunk in pcm.chunks(CHUNK_SIZE) {
          40  +
            yield Ok(AudioStream::AudioEvent(
          41  +
                AudioEvent::builder().audio_chunk(Blob::new(chunk)).build(),
          42  +
            ));
          43  +
        }
          44  +
    };
          45  +
          46  +
    let mut output = client
          47  +
        .start_stream_transcription()
          48  +
        .language_code(LanguageCode::EnGb)
          49  +
        .media_sample_rate_hertz(8000)
          50  +
        .media_encoding(MediaEncoding::Pcm)
          51  +
        .audio_stream(input_stream.into())
          52  +
        .send()
          53  +
        .await?;
          54  +
          55  +
    let mut full_message = String::new();
          56  +
    while let Some(event) = output.transcript_result_stream.recv().await? {
          57  +
        match event {
          58  +
            TranscriptResultStream::TranscriptEvent(transcript_event) => {
          59  +
                let transcript = transcript_event.transcript.unwrap();
          60  +
                for result in transcript.results.unwrap_or_default() {
          61  +
                    if !result.is_partial {
          62  +
                        let first_alternative = &result.alternatives.as_ref().unwrap()[0];
          63  +
                        full_message += first_alternative.transcript.as_ref().unwrap();
          64  +
                        full_message.push(' ');
          65  +
                    }
          66  +
                }
          67  +
            }
          68  +
            otherwise => panic!("received unexpected event type: {otherwise:?}"),
          69  +
        }
          70  +
    }
          71  +
    Ok(full_message)
          72  +
}
          73  +
          74  +
/// Test that the schema-based path (SdkConfig → SharedClientProtocol) produces
          75  +
/// correct requests, matching the canary's code path.
          76  +
#[tokio::test]
          77  +
async fn test_schema_path_with_replaying_client() {
          78  +
    let events: Vec<Event> = serde_json::from_str(include_str!("success.json")).unwrap();
          79  +
    let replayer = ReplayingClient::new(events);
          80  +
    let client = client_from_sdk_config(replayer.clone());
          81  +
    let result = run_transcribe(&client)
          82  +
        .await
          83  +
        .expect("transcription should succeed");
          84  +
    assert!(
          85  +
        !result.trim().is_empty(),
          86  +
        "transcription result should not be empty"
          87  +
    );
          88  +
    replayer
          89  +
        .validate(&["content-type", "content-length"], |expected, actual| {
          90  +
            aws_smithy_eventstream::test_util::validate_body(expected, actual, true)
          91  +
        })
          92  +
        .await
          93  +
        .unwrap();
          94  +
}
          95  +
          96  +
/// Verify that event stream requests do NOT have a Content-Length header.
          97  +
/// The protocol's serialize_request may set Content-Length from the initial
          98  +
/// empty body, but it must be removed when the body is replaced with the
          99  +
/// streaming event stream. A stale Content-Length: 0 causes the service to
         100  +
/// cancel the HTTP/2 stream immediately.
         101  +
#[tokio::test]
         102  +
async fn test_event_stream_no_content_length() {
         103  +
    let events: Vec<Event> = serde_json::from_str(include_str!("success.json")).unwrap();
         104  +
    let replayer = ReplayingClient::new(events);
         105  +
    let client = client_from_sdk_config(replayer.clone());
         106  +
    let _ = run_transcribe(&client).await;
         107  +
    let requests = replayer.take_requests().await;
         108  +
    let first = requests.first().expect("should have at least one request");
         109  +
    assert!(
         110  +
        first.headers().get("content-length").is_none(),
         111  +
        "event stream request must not have Content-Length header, \
         112  +
         but found: {:?}",
         113  +
        first.headers().get("content-length"),
         114  +
    );
         115  +
}
         116  +
         117  +
fn pcm_data() -> Vec<u8> {
         118  +
    let reader = hound::WavReader::new(&include_bytes!("hello-transcribe-8000.wav")[..])
         119  +
        .expect("valid wav data");
         120  +
    let samples_result: hound::Result<Vec<i16>> = reader.into_samples::<i16>().collect();
         121  +
    let mut pcm: Vec<u8> = Vec::new();
         122  +
    for sample in samples_result.unwrap() {
         123  +
        pcm.put_i16_le(sample);
         124  +
    }
         125  +
    pcm
         126  +
}

tmp-codegen-diff/aws-sdk/tests/no-default-features/Cargo.toml

@@ -2,2 +54,54 @@
   22     22   
default-features = false
   23     23   
version = "0.0.0-local"
   24     24   
   25     25   
[dev-dependencies.aws-smithy-async]
   26     26   
path = "../../sdk/aws-smithy-async"
   27     27   
version = "1.2.14"
   28     28   
   29     29   
[dev-dependencies.aws-smithy-runtime]
   30     30   
path = "../../sdk/aws-smithy-runtime"
   31     31   
features = ["test-util"]
   32         -
version = "1.10.3"
          32  +
version = "1.10.4"
   33     33   
   34     34   
[dev-dependencies.aws-smithy-http-client]
   35     35   
path = "../../sdk/aws-smithy-http-client"
   36     36   
features = ["test-util"]
   37     37   
version = "1.1.12"
   38     38   
   39     39   
[dev-dependencies.aws-credential-types]
   40     40   
path = "../../sdk/aws-credential-types"
   41     41   
features = ["test-util"]
   42     42   
version = "1.2.14"

tmp-codegen-diff/aws-sdk/tests/telemetry/Cargo.toml

@@ -1,1 +65,65 @@
   16     16   
tracing-fluent-assertions = "0.3.0"
   17     17   
   18     18   
[dev-dependencies.aws-config]
   19     19   
path = "../../sdk/aws-config"
   20     20   
features = ["test-util", "behavior-version-latest"]
   21     21   
version = "1.9.0"
   22     22   
   23     23   
[dev-dependencies.aws-runtime]
   24     24   
path = "../../sdk/aws-runtime"
   25     25   
features = ["test-util"]
   26         -
version = "1.7.3"
          26  +
version = "1.7.4"
   27     27   
   28     28   
[dev-dependencies.aws-sdk-dynamodb]
   29     29   
path = "../../sdk/dynamodb"
   30     30   
features = ["test-util", "behavior-version-latest"]
   31     31   
version = "0.0.0-local"
   32     32   
   33     33   
[dev-dependencies.aws-sdk-s3]
   34     34   
path = "../../sdk/s3"
   35     35   
features = ["test-util", "behavior-version-latest"]
   36     36   
version = "0.0.0-local"
   37     37   
   38     38   
[dev-dependencies.aws-smithy-observability]
   39     39   
path = "../../sdk/aws-smithy-observability"
   40     40   
version = "0.2.6"
   41     41   
   42     42   
[dev-dependencies.aws-smithy-observability-otel]
   43     43   
path = "../../sdk/aws-smithy-observability-otel"
   44     44   
version = "0.1.11"
   45     45   
   46     46   
[dev-dependencies.aws-smithy-runtime]
   47     47   
path = "../../sdk/aws-smithy-runtime"
   48     48   
features = ["client", "test-util"]
   49         -
version = "1.10.3"
          49  +
version = "1.10.4"
   50     50   
   51     51   
[dev-dependencies.aws-smithy-types]
   52     52   
path = "../../sdk/aws-smithy-types"
   53     53   
version = "1.4.7"
   54     54   
   55     55   
[dev-dependencies.opentelemetry]
   56     56   
version = "0.26.0"
   57     57   
features = ["metrics"]
   58     58   
   59     59   
[dev-dependencies.opentelemetry_sdk]