marcoferrer / kroto-plus

gRPC Kotlin Coroutines, Protobuf DSL, Scripting for Protoc
Apache License 2.0
494 stars 28 forks source link

Implement outbound flow control #42

Closed marcoferrer closed 5 years ago

marcoferrer commented 5 years ago

Prevent excessive buffering on the outbound stream observer using manual flow control

codecov-io commented 5 years ago

Codecov Report

:exclamation: No coverage uploaded for pull request base (develop@a1129f6). Click here to learn what that means. The diff coverage is 88.88%.

Impacted file tree graph

@@            Coverage Diff            @@
##             develop     #42   +/-   ##
=========================================
  Coverage           ?   88.8%           
  Complexity         ?      19           
=========================================
  Files              ?      14           
  Lines              ?     259           
  Branches           ?      37           
=========================================
  Hits               ?     230           
  Misses             ?      10           
  Partials           ?      19
Impacted Files Coverage Δ Complexity Δ
...s/coroutines/client/ClientResponseStreamChannel.kt 100% <100%> (ø) 9 <9> (?)
...rrer/krotoplus/coroutines/server/ServerChannels.kt 88.88% <100%> (ø) 0 <0> (?)
...ithub/marcoferrer/krotoplus/coroutines/RpcUtils.kt 87.5% <100%> (ø) 0 <0> (?)
...oferrer/krotoplus/coroutines/client/ClientCalls.kt 96.29% <100%> (ø) 0 <0> (?)
...otoplus/coroutines/client/ClientBidiCallChannel.kt 100% <100%> (ø) 0 <0> (?)
...rcoferrer/krotoplus/coroutines/call/FlowControl.kt 80% <76.47%> (ø) 0 <0> (?)
.../marcoferrer/krotoplus/coroutines/call/CallExts.kt 88.57% <80%> (ø) 0 <0> (?)
...utines/call/FlowControlledInboundStreamObserver.kt 82.6% <82.6%> (ø) 0 <0> (?)
...us/coroutines/client/ClientStreamingCallChannel.kt 85.71% <85.71%> (ø) 0 <0> (?)
...oferrer/krotoplus/coroutines/server/ServerCalls.kt 86.07% <90%> (ø) 0 <0> (?)

Continue to review full report at Codecov.

Legend - Click here to learn more Δ = absolute <relative> (impact), ø = not affected, ? = missing data Powered by Codecov. Last update a1129f6...c7a09a7. Read the comment docs.