From 143c3ea16bf086be3a24e1fec24b3fceb8bee6ae Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sun, 7 Aug 2016 13:09:11 +0700 Subject: [PATCH] remove unused connectionParametersManager from Stream --- session.go | 2 +- stream.go | 3 +-- stream_test.go | 2 +- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/session.go b/session.go index d839f824..d0dd0623 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.connectionParametersManager, s.flowControlManager, id) + stream, err := newStream(s.scheduleSending, s.flowControlManager, id) if err != nil { return nil, err } diff --git a/stream.go b/stream.go index ecfc5de8..4d0e540c 100644 --- a/stream.go +++ b/stream.go @@ -7,7 +7,6 @@ import ( "github.com/lucas-clemente/quic-go/flowcontrol" "github.com/lucas-clemente/quic-go/frames" - "github.com/lucas-clemente/quic-go/handshake" "github.com/lucas-clemente/quic-go/protocol" "github.com/lucas-clemente/quic-go/qerr" "github.com/lucas-clemente/quic-go/utils" @@ -44,7 +43,7 @@ type stream struct { } // newStream creates a new Stream -func newStream(onData func(), connectionParameterManager *handshake.ConnectionParametersManager, flowControlManager flowcontrol.FlowControlManager, StreamID protocol.StreamID) (*stream, error) { +func newStream(onData func(), flowControlManager flowcontrol.FlowControlManager, StreamID protocol.StreamID) (*stream, error) { s := &stream{ onData: onData, streamID: StreamID, diff --git a/stream_test.go b/stream_test.go index 2e4f5a69..33212f78 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, cpm, flowControlManager, streamID) + str, _ = newStream(onData, flowControlManager, streamID) }) It("gets stream id", func() {