@@ -174,31 +174,31 @@ class HttpProtocolClientGeneratorTests {
174174 val contents = getFileContents(context.manifest, " /RestJson/RestJsonProtocolClient.swift" )
175175 contents.shouldSyntacticSanityCheck()
176176 val expected = """
177- public func unsignedFooBlobStreamWithLength (input: UnsignedFooBlobStreamWithLengthInput ) async throws -> UnsignedFooBlobStreamWithLengthOutput {
177+ public func explicitBlobStreamWithLength (input: ExplicitBlobStreamWithLengthInput ) async throws -> ExplicitBlobStreamWithLengthOutput {
178178 let context = ClientRuntime.HttpContextBuilder()
179179 .withEncoder(value: encoder)
180180 .withDecoder(value: decoder)
181181 .withMethod(value: .post)
182182 .withServiceName(value: serviceName)
183- .withOperation(value: "unsignedFooBlobStreamWithLength ")
183+ .withOperation(value: "explicitBlobStreamWithLength ")
184184 .withIdempotencyTokenGenerator(value: config.idempotencyTokenGenerator)
185185 .withLogger(value: config.logger)
186186 .withPartitionID(value: config.partitionID)
187187 .withAuthSchemes(value: config.authSchemes ?? [])
188188 .withAuthSchemeResolver(value: config.authSchemeResolver)
189- .withUnsignedPayloadTrait(value: true )
189+ .withUnsignedPayloadTrait(value: false )
190190 .build()
191- var operation = ClientRuntime.OperationStack<UnsignedFooBlobStreamWithLengthInput, UnsignedFooBlobStreamWithLengthOutput >(id: "unsignedFooBlobStreamWithLength ")
192- operation.initializeStep.intercept(position: .after, middleware: ClientRuntime.URLPathMiddleware<UnsignedFooBlobStreamWithLengthInput, UnsignedFooBlobStreamWithLengthOutput>(UnsignedFooBlobStreamWithLengthInput .urlPathProvider(_:)))
193- operation.initializeStep.intercept(position: .after, middleware: ClientRuntime.URLHostMiddleware<UnsignedFooBlobStreamWithLengthInput, UnsignedFooBlobStreamWithLengthOutput >())
194- operation.buildStep.intercept(position: .before, middleware: ClientRuntime.AuthSchemeMiddleware<UnsignedFooBlobStreamWithLengthOutput >())
195- operation.serializeStep.intercept(position: .after, middleware: ContentTypeMiddleware<UnsignedFooBlobStreamWithLengthInput, UnsignedFooBlobStreamWithLengthOutput >(contentType: "application/octet-stream"))
196- operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.BlobStreamBodyMiddleware<UnsignedFooBlobStreamWithLengthInput, UnsignedFooBlobStreamWithLengthOutput >(keyPath: \.payload1))
197- operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.ContentLengthMiddleware(requiresLength: true, unsignedPayload: true ))
198- operation.finalizeStep.intercept(position: .after, middleware: ClientRuntime.RetryMiddleware<ClientRuntime.DefaultRetryStrategy, ClientRuntime.DefaultRetryErrorInfoProvider, UnsignedFooBlobStreamWithLengthOutput >(options: config.retryStrategyOptions))
199- operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.SignerMiddleware<UnsignedFooBlobStreamWithLengthOutput >())
200- operation.deserializeStep.intercept(position: .after, middleware: ClientRuntime.DeserializeMiddleware<UnsignedFooBlobStreamWithLengthOutput >(responseClosure(decoder: decoder), responseErrorClosure(UnsignedFooBlobStreamWithLengthOutputError .self, decoder: decoder)))
201- operation.deserializeStep.intercept(position: .after, middleware: ClientRuntime.LoggerMiddleware<UnsignedFooBlobStreamWithLengthOutput >(clientLogMode: config.clientLogMode))
191+ var operation = ClientRuntime.OperationStack<ExplicitBlobStreamWithLengthInput, ExplicitBlobStreamWithLengthOutput >(id: "explicitBlobStreamWithLength ")
192+ operation.initializeStep.intercept(position: .after, middleware: ClientRuntime.URLPathMiddleware<ExplicitBlobStreamWithLengthInput, ExplicitBlobStreamWithLengthOutput>(ExplicitBlobStreamWithLengthInput .urlPathProvider(_:)))
193+ operation.initializeStep.intercept(position: .after, middleware: ClientRuntime.URLHostMiddleware<ExplicitBlobStreamWithLengthInput, ExplicitBlobStreamWithLengthOutput >())
194+ operation.buildStep.intercept(position: .before, middleware: ClientRuntime.AuthSchemeMiddleware<ExplicitBlobStreamWithLengthOutput >())
195+ operation.serializeStep.intercept(position: .after, middleware: ContentTypeMiddleware<ExplicitBlobStreamWithLengthInput, ExplicitBlobStreamWithLengthOutput >(contentType: "application/octet-stream"))
196+ operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.BlobStreamBodyMiddleware<ExplicitBlobStreamWithLengthInput, ExplicitBlobStreamWithLengthOutput >(keyPath: \.payload1))
197+ operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.ContentLengthMiddleware(requiresLength: true, unsignedPayload: false ))
198+ operation.finalizeStep.intercept(position: .after, middleware: ClientRuntime.RetryMiddleware<ClientRuntime.DefaultRetryStrategy, ClientRuntime.DefaultRetryErrorInfoProvider, ExplicitBlobStreamWithLengthOutput >(options: config.retryStrategyOptions))
199+ operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.SignerMiddleware<ExplicitBlobStreamWithLengthOutput >())
200+ operation.deserializeStep.intercept(position: .after, middleware: ClientRuntime.DeserializeMiddleware<ExplicitBlobStreamWithLengthOutput >(responseClosure(decoder: decoder), responseErrorClosure(ExplicitBlobStreamWithLengthOutputError .self, decoder: decoder)))
201+ operation.deserializeStep.intercept(position: .after, middleware: ClientRuntime.LoggerMiddleware<ExplicitBlobStreamWithLengthOutput >(clientLogMode: config.clientLogMode))
202202 let result = try await operation.handleMiddleware(context: context, input: input, next: client.getHandler())
203203 return result
204204 }
0 commit comments