Skip to content

Commit 952c9f3

Browse files
committed
rename byteBuffer to bytes and remove Collection overload
1 parent e249213 commit 952c9f3

File tree

3 files changed

+10
-24
lines changed

3 files changed

+10
-24
lines changed

Sources/AsyncHTTPClient/AsyncAwait/HTTPClientRequest.swift

Lines changed: 7 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -54,16 +54,16 @@ extension HTTPClientRequest {
5454

5555
@available(macOS 10.15, iOS 13.0, watchOS 6.0, tvOS 13.0, *)
5656
extension HTTPClientRequest.Body {
57-
public static func byteBuffer(_ byteBuffer: ByteBuffer) -> Self {
57+
58+
public static func bytes(_ byteBuffer: ByteBuffer) -> Self {
5859
self.init(.byteBuffer(byteBuffer))
5960
}
6061

6162
@inlinable
62-
public static func bytes<Bytes: Sequence>(
63-
length: Int?,
63+
public static func bytes<Bytes: RandomAccessCollection>(
6464
_ bytes: Bytes
6565
) -> Self where Bytes.Element == UInt8 {
66-
self.init(.sequence(length: length, canBeConsumedMultipleTimes: false) { allocator in
66+
self.init(.sequence(length: bytes.count, canBeConsumedMultipleTimes: true) { allocator in
6767
if let buffer = bytes.withContiguousStorageIfAvailable({ allocator.buffer(bytes: $0) }) {
6868
// fastpath
6969
return buffer
@@ -72,27 +72,13 @@ extension HTTPClientRequest.Body {
7272
return allocator.buffer(bytes: bytes)
7373
})
7474
}
75-
75+
7676
@inlinable
77-
public static func bytes<Bytes: Collection>(
77+
public static func bytes<Bytes: Sequence>(
7878
length: Int?,
7979
_ bytes: Bytes
8080
) -> Self where Bytes.Element == UInt8 {
81-
self.init(.sequence(length: length, canBeConsumedMultipleTimes: true) { allocator in
82-
if let buffer = bytes.withContiguousStorageIfAvailable({ allocator.buffer(bytes: $0) }) {
83-
// fastpath
84-
return buffer
85-
}
86-
// potentially really slow path
87-
return allocator.buffer(bytes: bytes)
88-
})
89-
}
90-
91-
@inlinable
92-
public static func bytes<Bytes: RandomAccessCollection>(
93-
_ bytes: Bytes
94-
) -> Self where Bytes.Element == UInt8 {
95-
self.init(.sequence(length: bytes.count, canBeConsumedMultipleTimes: true) { allocator in
81+
self.init(.sequence(length: length, canBeConsumedMultipleTimes: bytes is Collection) { allocator in
9682
if let buffer = bytes.withContiguousStorageIfAvailable({ allocator.buffer(bytes: $0) }) {
9783
// fastpath
9884
return buffer

Tests/AsyncHTTPClientTests/AsyncAwaitEndToEndTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ final class AsyncAwaitEndToEndTests: XCTestCase {
9090
let logger = Logger(label: "HTTPClient", factory: StreamLogHandler.standardOutput(label:))
9191
var request = HTTPClientRequest(url: "https://localhost:\(bin.port)/")
9292
request.method = .POST
93-
request.body = .byteBuffer(ByteBuffer(string: "1234"))
93+
request.body = .bytes(ByteBuffer(string: "1234"))
9494

9595
guard let response = await XCTAssertNoThrowWithResult(
9696
try await client.execute(request, deadline: .now() + .seconds(10), logger: logger)

Tests/AsyncHTTPClientTests/HTTPClientRequestTests.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,7 @@ class HTTPClientRequestTests: XCTestCase {
225225
XCTAsyncTest {
226226
var request = Request(url: "http://example.com/post")
227227
request.method = .POST
228-
request.body = .byteBuffer(ByteBuffer())
228+
request.body = .bytes(ByteBuffer())
229229
var preparedRequest: PreparedRequest?
230230
XCTAssertNoThrow(preparedRequest = try PreparedRequest(request))
231231
guard let preparedRequest = preparedRequest else { return }
@@ -261,7 +261,7 @@ class HTTPClientRequestTests: XCTestCase {
261261
XCTAsyncTest {
262262
var request = Request(url: "http://example.com/post")
263263
request.method = .POST
264-
request.body = .byteBuffer(.init(string: "post body"))
264+
request.body = .bytes(.init(string: "post body"))
265265
var preparedRequest: PreparedRequest?
266266
XCTAssertNoThrow(preparedRequest = try PreparedRequest(request))
267267
guard let preparedRequest = preparedRequest else { return }

0 commit comments

Comments
 (0)