commit 43d2fcc6642cdcb55064bd9109057220dc3f347d
author nathanmittler <nathanmittler@google.com> Fri Aug 29 21:58:54 2014 -0700
committer Eric Anderson <ejona@google.com> Thu Jan 08 14:42:40 2015 -0800
tree 1bdcea88a8b27a332250fda581147cddb8f4f5c2
parent 048649e5e4a47a92b2e8e5236322e4033089a585

Adding inbound flow control to Netty client and server transports.

-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=74444530

core/src/main/java/com/google/net/stubby/newtransport/Deframer.java

diff --git a/core/src/main/java/com/google/net/stubby/newtransport/Deframer.java b/core/src/main/java/com/google/net/stubby/newtransport/Deframer.java
index fc9a306..f709a5d 100644
--- a/core/src/main/java/com/google/net/stubby/newtransport/Deframer.java
+++ b/core/src/main/java/com/google/net/stubby/newtransport/Deframer.java
@@ -23,13 +23,13 @@
    */
   private static final int LENGTH_NOT_SET = -1;
 
-  private final GrpcMessageListener target;
+  private final StreamListener target;
   private boolean inFrame;
   private byte currentFlags;
   private int currentLength = LENGTH_NOT_SET;
   private boolean statusDelivered;
 
-  public Deframer(GrpcMessageListener target) {
+  public Deframer(StreamListener target) {
     this.target = target;
   }
 
@@ -85,7 +85,7 @@
           framedChunk = new ByteArrayInputStream(ByteStreams.toByteArray(framedChunk));
           try {
             // Report payload to the receiving operation
-            target.onPayload(framedChunk, currentLength);
+            target.messageRead(framedChunk, currentLength);
           } finally {
             currentLength = LENGTH_NOT_SET;
             inFrame = false;
@@ -98,7 +98,7 @@
           Transport.ContextValue contextValue = Transport.ContextValue.parseFrom(framedChunk);
           try {
             ByteString value = contextValue.getValue();
-            target.onContext(contextValue.getKey(), value.newInput(), value.size());
+            target.contextRead(contextValue.getKey(), value.newInput(), value.size());
           } finally {
             currentLength = LENGTH_NOT_SET;
             inFrame = false;
@@ -154,7 +154,7 @@
   }
 
   private void writeStatus(Status status) {
-    target.onStatus(status);
+    target.closed(status);
     statusDelivered = true;
   }