123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211 |
- // Code generated by MockGen. DO NOT EDIT.
- // Source: github.com/lucas-clemente/quic-go (interfaces: StreamManager)
- // Package quic is a generated GoMock package.
- package quic
- import (
- reflect "reflect"
- gomock "github.com/golang/mock/gomock"
- handshake "github.com/lucas-clemente/quic-go/internal/handshake"
- protocol "github.com/lucas-clemente/quic-go/internal/protocol"
- wire "github.com/lucas-clemente/quic-go/internal/wire"
- )
- // MockStreamManager is a mock of StreamManager interface
- type MockStreamManager struct {
- ctrl *gomock.Controller
- recorder *MockStreamManagerMockRecorder
- }
- // MockStreamManagerMockRecorder is the mock recorder for MockStreamManager
- type MockStreamManagerMockRecorder struct {
- mock *MockStreamManager
- }
- // NewMockStreamManager creates a new mock instance
- func NewMockStreamManager(ctrl *gomock.Controller) *MockStreamManager {
- mock := &MockStreamManager{ctrl: ctrl}
- mock.recorder = &MockStreamManagerMockRecorder{mock}
- return mock
- }
- // EXPECT returns an object that allows the caller to indicate expected use
- func (m *MockStreamManager) EXPECT() *MockStreamManagerMockRecorder {
- return m.recorder
- }
- // AcceptStream mocks base method
- func (m *MockStreamManager) AcceptStream() (Stream, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "AcceptStream")
- ret0, _ := ret[0].(Stream)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // AcceptStream indicates an expected call of AcceptStream
- func (mr *MockStreamManagerMockRecorder) AcceptStream() *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AcceptStream", reflect.TypeOf((*MockStreamManager)(nil).AcceptStream))
- }
- // AcceptUniStream mocks base method
- func (m *MockStreamManager) AcceptUniStream() (ReceiveStream, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "AcceptUniStream")
- ret0, _ := ret[0].(ReceiveStream)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // AcceptUniStream indicates an expected call of AcceptUniStream
- func (mr *MockStreamManagerMockRecorder) AcceptUniStream() *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AcceptUniStream", reflect.TypeOf((*MockStreamManager)(nil).AcceptUniStream))
- }
- // CloseWithError mocks base method
- func (m *MockStreamManager) CloseWithError(arg0 error) {
- m.ctrl.T.Helper()
- m.ctrl.Call(m, "CloseWithError", arg0)
- }
- // CloseWithError indicates an expected call of CloseWithError
- func (mr *MockStreamManagerMockRecorder) CloseWithError(arg0 interface{}) *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CloseWithError", reflect.TypeOf((*MockStreamManager)(nil).CloseWithError), arg0)
- }
- // DeleteStream mocks base method
- func (m *MockStreamManager) DeleteStream(arg0 protocol.StreamID) error {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "DeleteStream", arg0)
- ret0, _ := ret[0].(error)
- return ret0
- }
- // DeleteStream indicates an expected call of DeleteStream
- func (mr *MockStreamManagerMockRecorder) DeleteStream(arg0 interface{}) *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteStream", reflect.TypeOf((*MockStreamManager)(nil).DeleteStream), arg0)
- }
- // GetOrOpenReceiveStream mocks base method
- func (m *MockStreamManager) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "GetOrOpenReceiveStream", arg0)
- ret0, _ := ret[0].(receiveStreamI)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // GetOrOpenReceiveStream indicates an expected call of GetOrOpenReceiveStream
- func (mr *MockStreamManagerMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamManager)(nil).GetOrOpenReceiveStream), arg0)
- }
- // GetOrOpenSendStream mocks base method
- func (m *MockStreamManager) GetOrOpenSendStream(arg0 protocol.StreamID) (sendStreamI, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "GetOrOpenSendStream", arg0)
- ret0, _ := ret[0].(sendStreamI)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // GetOrOpenSendStream indicates an expected call of GetOrOpenSendStream
- func (mr *MockStreamManagerMockRecorder) GetOrOpenSendStream(arg0 interface{}) *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetOrOpenSendStream", reflect.TypeOf((*MockStreamManager)(nil).GetOrOpenSendStream), arg0)
- }
- // HandleMaxStreamsFrame mocks base method
- func (m *MockStreamManager) HandleMaxStreamsFrame(arg0 *wire.MaxStreamsFrame) error {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "HandleMaxStreamsFrame", arg0)
- ret0, _ := ret[0].(error)
- return ret0
- }
- // HandleMaxStreamsFrame indicates an expected call of HandleMaxStreamsFrame
- func (mr *MockStreamManagerMockRecorder) HandleMaxStreamsFrame(arg0 interface{}) *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "HandleMaxStreamsFrame", reflect.TypeOf((*MockStreamManager)(nil).HandleMaxStreamsFrame), arg0)
- }
- // OpenStream mocks base method
- func (m *MockStreamManager) OpenStream() (Stream, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "OpenStream")
- ret0, _ := ret[0].(Stream)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // OpenStream indicates an expected call of OpenStream
- func (mr *MockStreamManagerMockRecorder) OpenStream() *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OpenStream", reflect.TypeOf((*MockStreamManager)(nil).OpenStream))
- }
- // OpenStreamSync mocks base method
- func (m *MockStreamManager) OpenStreamSync() (Stream, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "OpenStreamSync")
- ret0, _ := ret[0].(Stream)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // OpenStreamSync indicates an expected call of OpenStreamSync
- func (mr *MockStreamManagerMockRecorder) OpenStreamSync() *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OpenStreamSync", reflect.TypeOf((*MockStreamManager)(nil).OpenStreamSync))
- }
- // OpenUniStream mocks base method
- func (m *MockStreamManager) OpenUniStream() (SendStream, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "OpenUniStream")
- ret0, _ := ret[0].(SendStream)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // OpenUniStream indicates an expected call of OpenUniStream
- func (mr *MockStreamManagerMockRecorder) OpenUniStream() *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OpenUniStream", reflect.TypeOf((*MockStreamManager)(nil).OpenUniStream))
- }
- // OpenUniStreamSync mocks base method
- func (m *MockStreamManager) OpenUniStreamSync() (SendStream, error) {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "OpenUniStreamSync")
- ret0, _ := ret[0].(SendStream)
- ret1, _ := ret[1].(error)
- return ret0, ret1
- }
- // OpenUniStreamSync indicates an expected call of OpenUniStreamSync
- func (mr *MockStreamManagerMockRecorder) OpenUniStreamSync() *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OpenUniStreamSync", reflect.TypeOf((*MockStreamManager)(nil).OpenUniStreamSync))
- }
- // UpdateLimits mocks base method
- func (m *MockStreamManager) UpdateLimits(arg0 *handshake.TransportParameters) error {
- m.ctrl.T.Helper()
- ret := m.ctrl.Call(m, "UpdateLimits", arg0)
- ret0, _ := ret[0].(error)
- return ret0
- }
- // UpdateLimits indicates an expected call of UpdateLimits
- func (mr *MockStreamManagerMockRecorder) UpdateLimits(arg0 interface{}) *gomock.Call {
- mr.mock.ctrl.T.Helper()
- return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateLimits", reflect.TypeOf((*MockStreamManager)(nil).UpdateLimits), arg0)
- }
|