Skip to content

Commit 7c2528e

Browse files
committed
Format and lint
1 parent 2222adb commit 7c2528e

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

Tests/GRPCCoreTests/Call/Server/Internal/ServerRPCExecutorTests.swift

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -423,10 +423,13 @@ final class ServerRPCExecutorTests: XCTestCase {
423423
var rpcErrorMetadata: Metadata { ["error": "yes"] }
424424
}
425425

426-
let harness = ServerRPCExecutorTestHarness(interceptors: [.throwInMessageSequence(CustomError())])
426+
let harness = ServerRPCExecutorTestHarness(interceptors: [
427+
.throwInMessageSequence(CustomError())
428+
])
427429
try await harness.execute(handler: .echo) { inbound in
428430
try await inbound.write(.metadata(["foo": "bar"]))
429-
try await inbound.write(.message([0])) // the sequence throws instantly, this should not arrive
431+
// the sequence throws instantly, this should not arrive
432+
try await inbound.write(.message([0]))
430433
await inbound.finish()
431434
} consumer: { outbound in
432435
let parts = try await outbound.collect()

Tests/GRPCCoreTests/Test Utilities/Call/Client/ClientInterceptors.swift

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,9 @@ struct RejectAllClientInterceptor: ClientInterceptor {
9191
var response = try await next(request, context)
9292
switch response.accepted {
9393
case .success(var success):
94-
let stream = AsyncThrowingStream<StreamingClientResponse<Output>.Contents.BodyPart, any Error>.makeStream()
94+
let stream = AsyncThrowingStream<
95+
StreamingClientResponse<Output>.Contents.BodyPart, any Error
96+
>.makeStream()
9597
stream.continuation.finish(throwing: error)
9698

9799
success.bodyParts = RPCAsyncSequence(wrapping: stream.stream)

0 commit comments

Comments
 (0)