diff --git a/session.go b/session.go index d0dd06234..bc9ae48f2 100644 --- a/session.go +++ b/session.go @@ -617,7 +617,7 @@ func (s *Session) newStreamImpl(id protocol.StreamID) (*stream, error) { if strExists { return nil, fmt.Errorf("Session: stream with ID %d already exists", id) } - stream, err := newStream(s.scheduleSending, s.flowControlManager, id) + stream, err := newStream(id, s.scheduleSending, s.flowControlManager) if err != nil { return nil, err } diff --git a/stream.go b/stream.go index 4d0e540cb..fb220ab8d 100644 --- a/stream.go +++ b/stream.go @@ -43,7 +43,7 @@ type stream struct { } // newStream creates a new Stream -func newStream(onData func(), flowControlManager flowcontrol.FlowControlManager, StreamID protocol.StreamID) (*stream, error) { +func newStream(StreamID protocol.StreamID, onData func(), flowControlManager flowcontrol.FlowControlManager) (*stream, error) { s := &stream{ onData: onData, streamID: StreamID, diff --git a/stream_test.go b/stream_test.go index 33212f78a..33c2c20dd 100644 --- a/stream_test.go +++ b/stream_test.go @@ -110,7 +110,7 @@ var _ = Describe("Stream", func() { cpm := handshake.NewConnectionParamatersManager() flowControlManager := flowcontrol.NewFlowControlManager(cpm) flowControlManager.NewStream(streamID, true) - str, _ = newStream(onData, flowControlManager, streamID) + str, _ = newStream(streamID, onData, flowControlManager) }) It("gets stream id", func() {