diff --git a/server.go b/server.go index d2369bf9..b70dbe8c 100644 --- a/server.go +++ b/server.go @@ -85,7 +85,7 @@ type Server struct { } type options struct { - codec Codec + codec Codec maxConcurrentStreams uint32 } @@ -294,9 +294,9 @@ func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport. func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, srv *service, sd *StreamDesc) { ss := &serverStream{ - t: t, - s: stream, - p: &parser{s: stream}, + t: t, + s: stream, + p: &parser{s: stream}, codec: s.opts.codec, } if appErr := sd.Handler(srv.server, ss); appErr != nil { diff --git a/stream.go b/stream.go index 46e538f8..2aa160e2 100644 --- a/stream.go +++ b/stream.go @@ -112,20 +112,20 @@ func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, meth return nil, toRPCErr(err) } return &clientStream{ - t: t, - s: s, - p: &parser{s: s}, - desc: desc, + t: t, + s: s, + p: &parser{s: s}, + desc: desc, codec: cc.dopts.codec, }, nil } // clientStream implements a client side Stream. type clientStream struct { - t transport.ClientTransport - s *transport.Stream - p *parser - desc *StreamDesc + t transport.ClientTransport + s *transport.Stream + p *parser + desc *StreamDesc codec Codec } diff --git a/transport/control.go b/transport/control.go index 6baa634e..2ff97de1 100644 --- a/transport/control.go +++ b/transport/control.go @@ -60,7 +60,7 @@ func (windowUpdate) isItem() bool { } type settings struct { - ack bool + ack bool setting []http2.Setting }