Skip to content

Commit 5ad8225

Browse files
committed
Handle eos
1 parent bf0cc7b commit 5ad8225

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/src/rpc/web_rtc/web_rtc_transport_stream.dart

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ class WebRtcTransportStream extends GrpcTransportStream {
7373
..stream = headersRequest.stream
7474
..message = (grpc.RequestMessage()
7575
..hasMessage = true
76-
..eos = false
76+
..eos = true
7777
..packetMessage = (grpc.PacketMessage()
7878
..data = data
7979
..eom = true))
@@ -83,7 +83,7 @@ class WebRtcTransportStream extends GrpcTransportStream {
8383
..stream = headersRequest.stream
8484
..message = (grpc.RequestMessage()
8585
..hasMessage = true
86-
..eos = false
86+
..eos = index == chunks.length - 1
8787
..packetMessage = (grpc.PacketMessage()
8888
..data = chunk
8989
..eom = index == chunks.length - 1)));

0 commit comments

Comments
 (0)