@@ -30,7 +30,11 @@ class HTTPBodyOutputStreamBridgeTests: XCTestCase {
30
30
let requestBytes = ( 0 ... numBytes) . map { UInt8 ( $0) }
31
31
let requestChunks = requestBytes. chunks ( of: chunkSize)
32
32
let requestByteSequence = MockAsyncSequence ( elementsToVend: requestChunks, gatingProduction: false )
33
- let requestBody = HTTPBody ( requestByteSequence, length: . known( requestBytes. count) , iterationBehavior: . single)
33
+ let requestBody = HTTPBody (
34
+ requestByteSequence,
35
+ length: . known( Int64 ( requestBytes. count) ) ,
36
+ iterationBehavior: . single
37
+ )
34
38
35
39
// Create a pair of bound streams with a tiny buffer to be the bottleneck for backpressure.
36
40
var inputStream : InputStream ?
@@ -77,7 +81,11 @@ class HTTPBodyOutputStreamBridgeTests: XCTestCase {
77
81
let requestBytes = ( 0 ... numBytes) . map { UInt8 ( $0) }
78
82
let requestChunks = requestBytes. chunks ( of: chunkSize)
79
83
let requestByteSequence = MockAsyncSequence ( elementsToVend: requestChunks, gatingProduction: true )
80
- let requestBody = HTTPBody ( requestByteSequence, length: . known( requestBytes. count) , iterationBehavior: . single)
84
+ let requestBody = HTTPBody (
85
+ requestByteSequence,
86
+ length: . known( Int64 ( requestBytes. count) ) ,
87
+ iterationBehavior: . single
88
+ )
81
89
82
90
// Create a pair of bound streams with a tiny buffer to be the bottleneck for backpressure.
83
91
var inputStream : InputStream ?
@@ -129,7 +137,11 @@ class HTTPBodyOutputStreamBridgeTests: XCTestCase {
129
137
let requestBytes = ( 0 ... numBytes) . map { UInt8 ( $0) }
130
138
let requestChunks = requestBytes. chunks ( of: chunkSize)
131
139
let requestByteSequence = MockAsyncSequence ( elementsToVend: requestChunks, gatingProduction: true )
132
- let requestBody = HTTPBody ( requestByteSequence, length: . known( requestBytes. count) , iterationBehavior: . single)
140
+ let requestBody = HTTPBody (
141
+ requestByteSequence,
142
+ length: . known( Int64 ( requestBytes. count) ) ,
143
+ iterationBehavior: . single
144
+ )
133
145
134
146
// Create a pair of bound streams with a tiny buffer to be the bottleneck for backpressure.
135
147
var inputStream : InputStream ?
@@ -183,7 +195,11 @@ class HTTPBodyOutputStreamBridgeTests: XCTestCase {
183
195
let requestBytes = ( 0 ... numBytes) . map { UInt8 ( $0) }
184
196
let requestChunks = requestBytes. chunks ( of: chunkSize)
185
197
let requestByteSequence = MockAsyncSequence ( elementsToVend: requestChunks, gatingProduction: true )
186
- let requestBody = HTTPBody ( requestByteSequence, length: . known( requestBytes. count) , iterationBehavior: . single)
198
+ let requestBody = HTTPBody (
199
+ requestByteSequence,
200
+ length: . known( Int64 ( requestBytes. count) ) ,
201
+ iterationBehavior: . single
202
+ )
187
203
188
204
// Create a pair of bound streams with a tiny buffer to be the bottleneck for backpressure.
189
205
var inputStream : InputStream ?
@@ -240,7 +256,11 @@ class HTTPBodyOutputStreamBridgeTests: XCTestCase {
240
256
let requestBytes = ( 0 ... numBytes) . map { UInt8 ( $0) }
241
257
let requestChunks = requestBytes. chunks ( of: chunkSize)
242
258
let requestByteSequence = MockAsyncSequence ( elementsToVend: requestChunks, gatingProduction: true )
243
- let requestBody = HTTPBody ( requestByteSequence, length: . known( requestBytes. count) , iterationBehavior: . single)
259
+ let requestBody = HTTPBody (
260
+ requestByteSequence,
261
+ length: . known( Int64 ( requestBytes. count) ) ,
262
+ iterationBehavior: . single
263
+ )
244
264
245
265
// Create a pair of bound streams with a tiny buffer to be the bottleneck for backpressure.
246
266
var inputStream : InputStream ?
0 commit comments