Add support for indeterminate length messages. This will make using GRPC easier for non-proto payload types.

Sync to head

1 files changed, 3 insertions, 7 deletions

diff --git a/protobuf-nano/src/main/java/io/grpc/protobuf/nano/DeferredNanoProtoInputStream.java b/protobuf-nano/src/main/java/io/grpc/protobuf/nano/DeferredNanoProtoInputStream.java
index f0aa1af2e..8fed0fe58 100644
--- a/protobuf-nano/src/main/java/io/grpc/protobuf/nano/DeferredNanoProtoInputStream.java
+++ b/protobuf-nano/src/main/java/io/grpc/protobuf/nano/DeferredNanoProtoInputStream.java
@@ -36,6 +36,7 @@ import com.google.protobuf.nano.CodedOutputByteBufferNano;
 import com.google.protobuf.nano.MessageNano;
 
 import io.grpc.DeferredInputStream;
+import io.grpc.KnownLength;
 
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
@@ -46,7 +47,8 @@ import javax.annotation.Nullable;
 /**
  * Implementation of {@link DeferredInputStream} backed by a nano proto.
  */
-public class DeferredNanoProtoInputStream extends DeferredInputStream<MessageNano> {
+public class DeferredNanoProtoInputStream extends DeferredInputStream<MessageNano>
+    implements KnownLength {
 
   // DeferredNanoProtoInputStream is first initialized with a *message*. *partial* is initially
   // null.
@@ -128,10 +130,4 @@ public class DeferredNanoProtoInputStream extends DeferredInputStream<MessageNan
     }
     return 0;
   }
-
-  @Override
-  @Nullable
-  public MessageNano getDeferred() {
-    return message;
-  }
 }