gofmt

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,
+		t:     t,
-		s: stream,
+		s:     stream,
-		p: &parser{s: stream},
+		p:     &parser{s: stream},
 		codec: s.opts.codec,
 	}
 	if appErr := sd.Handler(srv.server, ss); appErr != nil {

stream.go

@@ -112,20 +112,20 @@ func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, meth
 		return nil, toRPCErr(err)
 	}
 	return &clientStream{
-		t:    t,
+		t:     t,
-		s:    s,
+		s:     s,
-		p:    &parser{s: s},
+		p:     &parser{s: s},
-		desc: desc,
+		desc:  desc,
 		codec: cc.dopts.codec,
 	}, nil
 }
 
 // clientStream implements a client side Stream.
 type clientStream struct {
-	t    transport.ClientTransport
+	t     transport.ClientTransport
-	s    *transport.Stream
+	s     *transport.Stream
-	p    *parser
+	p     *parser
-	desc *StreamDesc
+	desc  *StreamDesc
 	codec Codec
 }
 

transport/control.go

@@ -60,7 +60,7 @@ func (windowUpdate) isItem() bool {
 }
 
 type settings struct {
-	ack bool
+	ack     bool
 	setting []http2.Setting
 }