@@ -9,7 +9,6 @@ import aws.sdk.kotlin.crt.CrtRuntimeException
99import aws.sdk.kotlin.crt.NativeHandle
1010import aws.sdk.kotlin.crt.awsAssertOpSuccess
1111import aws.sdk.kotlin.crt.util.asAwsByteCursor
12- import aws.sdk.kotlin.crt.util.use
1312import kotlinx.cinterop.*
1413import libcrt.*
1514import kotlin.coroutines.Continuation
@@ -64,19 +63,18 @@ internal class HttpStreamNative(
6463 throw CrtRuntimeException (" aws_input_stream_new_from_cursor()" )
6564 }
6665
67- StableRef .create(WriteChunkRequest (cont, byteBuf, stream)).use { req ->
68- val chunkOpts = cValue< aws_http1_chunk_options> {
69- chunk_data_size = chunkData.size.convert()
70- chunk_data = stream
71- on_complete = staticCFunction(::onWriteChunkComplete)
72- user_data = req.asCPointer()
73- }
74- awsAssertOpSuccess(
75- aws_http1_stream_write_chunk(ptr, chunkOpts),
76- ) {
77- cleanupWriteChunkCbData(req)
78- " aws_http1_stream_write_chunk()"
79- }
66+ val req = StableRef .create(WriteChunkRequest (cont, byteBuf, stream))
67+ val chunkOpts = cValue< aws_http1_chunk_options> {
68+ chunk_data_size = chunkData.size.convert()
69+ chunk_data = stream
70+ on_complete = staticCFunction(::onWriteChunkComplete)
71+ user_data = req.asCPointer()
72+ }
73+ awsAssertOpSuccess(
74+ aws_http1_stream_write_chunk(ptr, chunkOpts),
75+ ) {
76+ cleanupWriteChunkCbData(req)
77+ " aws_http1_stream_write_chunk()"
8078 }
8179 }
8280
0 commit comments