|
25 | 25 | import java.util.stream.Collectors; |
26 | 26 | import software.amazon.smithy.codegen.core.Symbol; |
27 | 27 | import software.amazon.smithy.go.codegen.CodegenUtils; |
| 28 | +import software.amazon.smithy.go.codegen.EventStreamGenerator; |
28 | 29 | import software.amazon.smithy.go.codegen.GoWriter; |
29 | 30 | import software.amazon.smithy.go.codegen.ChainWritable; |
30 | 31 | import software.amazon.smithy.go.codegen.Writable; |
@@ -364,6 +365,16 @@ protected void generateEventStreamDeserializers( |
364 | 365 | var outputShape = model.expectShape(streamInfo.getOperation().getOutput().get()); |
365 | 366 | var functionName = ProtocolGenerator.getDocumentDeserializerFunctionName(outputShape, |
366 | 367 | context.getService(), context.getProtocolName()); |
| 368 | + if (EventStreamGenerator.isV2EventStream(model, streamInfo.getOperation())) { |
| 369 | + // all of the initial response members are filtered out in the |
| 370 | + // generated struct, so basically do nothing |
| 371 | + AwsEventStreamUtils.generateEventMessageRequestDeserializer(context, outputShape, |
| 372 | + (ctx, payloadTarget, operand) -> { |
| 373 | + ctx.getWriter().get().write("return v, nil"); |
| 374 | + }); |
| 375 | + continue; |
| 376 | + } |
| 377 | + |
367 | 378 | AwsEventStreamUtils.generateEventMessageRequestDeserializer(context, outputShape, |
368 | 379 | (ctx, payloadTarget, operand) -> { |
369 | 380 | AwsProtocolUtils.initializeJsonEventMessageDeserializer(ctx, "nil,"); |
|
0 commit comments