File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Sources/GRPC/AsyncAwaitSupport Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -397,10 +397,10 @@ extension GRPCClient {
397
397
try Task . checkCancellation ( )
398
398
for try await request in requests {
399
399
try Task . checkCancellation ( )
400
- try await call. sendMessage ( request)
400
+ try await call. requestStream . send ( request)
401
401
}
402
402
try Task . checkCancellation ( )
403
- try await call. sendEnd ( )
403
+ try await call. requestStream . finish ( )
404
404
try Task . checkCancellation ( )
405
405
}
406
406
return try await withTaskCancellationHandler {
@@ -431,10 +431,10 @@ extension GRPCClient {
431
431
try Task . checkCancellation ( )
432
432
for try await request in requests {
433
433
try Task . checkCancellation ( )
434
- try await call. sendMessage ( request)
434
+ try await call. requestStream . send ( request)
435
435
}
436
436
try Task . checkCancellation ( )
437
- try await call. sendEnd ( )
437
+ try await call. requestStream . finish ( )
438
438
} onCancel: {
439
439
Task . detached {
440
440
try await call. cancel ( )
You can’t perform that action at this time.
0 commit comments