/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 131 _, err := m.GetOrOpenReceiveStream(ids.firstIncomingUniStream) 159 str, err := m.GetOrOpenReceiveStream(id) 163 dstr, err := m.GetOrOpenReceiveStream(id) 170 _, err := m.GetOrOpenReceiveStream(id) 192 str, err := m.GetOrOpenReceiveStream(id) 196 dstr, err := m.GetOrOpenReceiveStream(id) 203 _, err := m.GetOrOpenReceiveStream(id) 298 _, err := m.GetOrOpenReceiveStream(id) 304 str, err := m.GetOrOpenReceiveStream(id) 311 str, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 160 str, err := m.GetOrOpenReceiveStream(id) 164 dstr, err := m.GetOrOpenReceiveStream(id) 171 _, err := m.GetOrOpenReceiveStream(id) 193 str, err := m.GetOrOpenReceiveStream(id) 197 dstr, err := m.GetOrOpenReceiveStream(id) 204 _, err := m.GetOrOpenReceiveStream(id) 308 _, err := m.GetOrOpenReceiveStream(id) 317 str, err := m.GetOrOpenReceiveStream(id) 324 str, err := m.GetOrOpenReceiveStream(id) 331 _, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 160 str, err := m.GetOrOpenReceiveStream(id) 164 dstr, err := m.GetOrOpenReceiveStream(id) 171 _, err := m.GetOrOpenReceiveStream(id) 193 str, err := m.GetOrOpenReceiveStream(id) 197 dstr, err := m.GetOrOpenReceiveStream(id) 204 _, err := m.GetOrOpenReceiveStream(id) 308 _, err := m.GetOrOpenReceiveStream(id) 317 str, err := m.GetOrOpenReceiveStream(id) 324 str, err := m.GetOrOpenReceiveStream(id) 331 _, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 158 str, err := m.GetOrOpenReceiveStream(id) 162 dstr, err := m.GetOrOpenReceiveStream(id) 169 _, err := m.GetOrOpenReceiveStream(id) 191 str, err := m.GetOrOpenReceiveStream(id) 195 dstr, err := m.GetOrOpenReceiveStream(id) 202 _, err := m.GetOrOpenReceiveStream(id) 297 _, err := m.GetOrOpenReceiveStream(id) 303 str, err := m.GetOrOpenReceiveStream(id) 310 str, err := m.GetOrOpenReceiveStream(id) 317 _, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 160 str, err := m.GetOrOpenReceiveStream(id) 164 dstr, err := m.GetOrOpenReceiveStream(id) 171 _, err := m.GetOrOpenReceiveStream(id) 193 str, err := m.GetOrOpenReceiveStream(id) 197 dstr, err := m.GetOrOpenReceiveStream(id) 204 _, err := m.GetOrOpenReceiveStream(id) 308 _, err := m.GetOrOpenReceiveStream(id) 317 str, err := m.GetOrOpenReceiveStream(id) 324 str, err := m.GetOrOpenReceiveStream(id) 331 _, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 131 _, err := m.GetOrOpenReceiveStream(ids.firstIncomingUniStream) 159 str, err := m.GetOrOpenReceiveStream(id) 163 dstr, err := m.GetOrOpenReceiveStream(id) 170 _, err := m.GetOrOpenReceiveStream(id) 192 str, err := m.GetOrOpenReceiveStream(id) 196 dstr, err := m.GetOrOpenReceiveStream(id) 203 _, err := m.GetOrOpenReceiveStream(id) 298 _, err := m.GetOrOpenReceiveStream(id) 304 str, err := m.GetOrOpenReceiveStream(id) 311 str, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 56 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 63 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 75 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 84 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 104 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 160 str, err := m.GetOrOpenReceiveStream(id) 164 dstr, err := m.GetOrOpenReceiveStream(id) 171 _, err := m.GetOrOpenReceiveStream(id) 193 str, err := m.GetOrOpenReceiveStream(id) 197 dstr, err := m.GetOrOpenReceiveStream(id) 204 _, err := m.GetOrOpenReceiveStream(id) 308 _, err := m.GetOrOpenReceiveStream(id) 317 str, err := m.GetOrOpenReceiveStream(id) 324 str, err := m.GetOrOpenReceiveStream(id) 331 _, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/ |
H A D | window_update_queue_test.go | 34 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(3)).Return(stream3, nil) 35 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(1)).Return(stream1, nil) 46 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil) 55 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(12)).Return(nil, nil) 64 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(5)).Return(stream5, nil) 82 streamGetter.EXPECT().GetOrOpenReceiveStream(protocol.StreamID(10)).Return(stream10, nil)
|
H A D | streams_map_test.go | 124 _, err := m.GetOrOpenReceiveStream(ids.firstIncomingUniStream) 152 str, err := m.GetOrOpenReceiveStream(id) 156 dstr, err := m.GetOrOpenReceiveStream(id) 163 _, err := m.GetOrOpenReceiveStream(id) 185 str, err := m.GetOrOpenReceiveStream(id) 189 dstr, err := m.GetOrOpenReceiveStream(id) 196 _, err := m.GetOrOpenReceiveStream(id) 271 _, err := m.GetOrOpenReceiveStream(id) 277 str, err := m.GetOrOpenReceiveStream(id) 284 str, err := m.GetOrOpenReceiveStream(id) [all …]
|
H A D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 47 func (mr *MockStreamGetterMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 49 …k, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamGetter)(nil).GetOrOpenReceiveStream), arg0)
|
H A D | mock_stream_manager_test.go | 96 func (m *MockStreamManager) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { func 105 func (mr *MockStreamManagerMockRecorder) GetOrOpenReceiveStream(arg0 interface{}) *gomock.Call { func 107 …, "GetOrOpenReceiveStream", reflect.TypeOf((*MockStreamManager)(nil).GetOrOpenReceiveStream), arg0)
|