Home
last modified time | relevance | path

Searched refs:GetOrOpenReceiveStream (Results 1 – 25 of 84) sorted by relevance

1234

/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dwindow_update_queue_test.go34 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 Dstreams_map_test.go131 _, 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go160 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go160 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go158 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go160 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go131 _, 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go160 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 Dmock_stream_getter_test.go38 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 Dwindow_update_queue_test.go34 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 Dstreams_map_test.go124 _, 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 Dmock_stream_getter_test.go38 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 Dmock_stream_manager_test.go96 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)

1234