diff --git a/okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java b/okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java index 85ed916095b..a1f9d58be1b 100644 --- a/okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java +++ b/okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java @@ -21,6 +21,7 @@ import io.grpc.Metadata; import io.grpc.Status; import io.grpc.internal.AbstractServerStream; +import io.grpc.internal.Protocol; import io.grpc.internal.StatsTraceContext; import io.grpc.internal.TransportTracer; import io.grpc.internal.WritableBuffer; @@ -164,7 +165,7 @@ public TransportState( int initialWindowSize, TransportTracer transportTracer, String methodName) { - super(maxMessageSize, statsTraceCtx, transportTracer); + super(maxMessageSize, statsTraceCtx, transportTracer, Protocol.GRPC); this.transport = Preconditions.checkNotNull(transport, "transport"); this.streamId = streamId; this.lock = Preconditions.checkNotNull(lock, "lock");