Skip to content

Commit c791fe7

Browse files
authored
grpc: Fix onReady() listener delegation (KRPC-220) (#477)
Subsystem gRPC/Native Problem Description Native gRPC server was only sending a single message during server side streaming. Solution The DeferredCallListener missed the onReady() implementation. Signed-off-by: Johannes Zottele <[email protected]>
1 parent 78da810 commit c791fe7

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

grpc/grpc-core/src/nativeMain/kotlin/kotlinx/rpc/grpc/internal/NativeServerCall.kt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -354,4 +354,5 @@ private class DeferredCallListener<T> : ServerCall.Listener<T>() {
354354
override fun onHalfClose() = deliver { it.onHalfClose() }
355355
override fun onCancel() = deliver { it.onCancel() }
356356
override fun onComplete() = deliver { it.onComplete() }
357+
override fun onReady() = deliver { it.onReady() }
357358
}

0 commit comments

Comments
 (0)