diff --git a/okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java b/okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java index 1def5c17e04..ebc284ba8e7 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; @@ -172,7 +173,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");