Skip to content

Commit d586c51

Browse files
authored
feat(rt): mark event stream HTTP body as full duplex (#687)
1 parent df2a604 commit d586c51

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
{
2+
"id": "6313ed78-29f9-4d71-af08-38b6a62bcd40",
3+
"type": "feature",
4+
"description": "Mark event stream HTTP body as duplex stream"
5+
}

aws-runtime/protocols/aws-event-stream/common/src/aws/sdk/kotlin/runtime/protocol/eventstream/FrameEncoder.kt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ public suspend fun Flow<ByteArray>.asEventStreamHttpBody(): HttpBody {
4444
return object : HttpBody.Streaming() {
4545
override val contentLength: Long? = null
4646
override val isReplayable: Boolean = false
47+
override val isDuplex: Boolean = true
4748
override fun readFrom(): SdkByteReadChannel {
4849
// FIXME - delaying launch here until the channel is consumed from the HTTP engine is a hacky way
4950
// of enforcing ordering to ensure the ExecutionContext is updated with the

0 commit comments

Comments
 (0)