grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Exposing AbstractBufferingHandler so it can be used by custom protocol negotiators.

This commit is contained in:
nmittler 2015-06-24 12:13:59 -07:00
parent 74490d5f6b
commit ae2b5bfda7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
netty/src/main/java/io/grpc/transport/netty/ProtocolNegotiators.java
View File

@ -181,7 +181,7 @@ public final class ProtocolNegotiators {
* write to a {@link Channel} before we are allowed to write to it officially i.e. * write to a {@link Channel} before we are allowed to write to it officially i.e.
* before it's active or the TLS Handshake is complete. * before it's active or the TLS Handshake is complete.
*/ */
private abstract static class AbstractBufferingHandler extends ChannelDuplexHandler { public abstract static class AbstractBufferingHandler extends ChannelDuplexHandler {
private ChannelHandler[] handlers; private ChannelHandler[] handlers;
private Queue<ChannelWrite> bufferedWrites = new ArrayDeque<ChannelWrite>(); private Queue<ChannelWrite> bufferedWrites = new ArrayDeque<ChannelWrite>();