mirror of https://github.com/grpc/grpc-java.git
7b8105e100
DelayedClientTransport needs to avoid becoming terminated while it owns RPCs. Previously DelayedClientTransport could terminate when some of its RPCs had their realStream but realStream.start() hadn't yet been called. To avoid that, we now make sure to call realStream.start() synchronously with setting realStream. Since start() and the method calls before start execute quickly, we can run it in-line. But it does mean we now need to split the Stream methods into "before start" and "after start" categories for queuing. Fixes #6283 |
||
|---|---|---|
| .. | ||
| src | ||
| BUILD.bazel | ||
| build.gradle | ||