/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 127 _, err := m.OpenStreamSync(ctx) 136 str, err := m.OpenStreamSync(context.Background()) 153 _, err := m.OpenStreamSync(ctx) 214 _, err := m.OpenStreamSync(ctx) 242 _, err := m.OpenStreamSync(context.Background()) 248 _, err := m.OpenStreamSync(context.Background()) 255 _, err := m.OpenStreamSync(context.Background()) 316 _, err := m.OpenStreamSync(context.Background()) 373 _, err := m.OpenStreamSync(context.Background()) 379 _, err := m.OpenStreamSync(context.Background()) [all …]
|
H A D | mock_stream_manager_test.go | 155 func (m *MockStreamManager) OpenStreamSync(arg0 context.Context) (Stream, error) { func 164 func (mr *MockStreamManagerMockRecorder) OpenStreamSync(arg0 interface{}) *gomock.Call { func 166 …thodType(mr.mock, "OpenStreamSync", reflect.TypeOf((*MockStreamManager)(nil).OpenStreamSync), arg0)
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 137 _, err := m.OpenStreamSync(ctx) 146 str, err := m.OpenStreamSync(context.Background()) 163 _, err := m.OpenStreamSync(ctx) 224 _, err := m.OpenStreamSync(ctx) 252 _, err := m.OpenStreamSync(context.Background()) 258 _, err := m.OpenStreamSync(context.Background()) 265 _, err := m.OpenStreamSync(context.Background()) 326 _, err := m.OpenStreamSync(context.Background()) 383 _, err := m.OpenStreamSync(context.Background()) 389 _, err := m.OpenStreamSync(context.Background()) [all …]
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 137 _, err := m.OpenStreamSync(ctx) 146 str, err := m.OpenStreamSync(context.Background()) 163 _, err := m.OpenStreamSync(ctx) 224 _, err := m.OpenStreamSync(ctx) 252 _, err := m.OpenStreamSync(context.Background()) 258 _, err := m.OpenStreamSync(context.Background()) 265 _, err := m.OpenStreamSync(context.Background()) 326 _, err := m.OpenStreamSync(context.Background()) 383 _, err := m.OpenStreamSync(context.Background()) 389 _, err := m.OpenStreamSync(context.Background()) [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 137 _, err := m.OpenStreamSync(ctx) 146 str, err := m.OpenStreamSync(context.Background()) 163 _, err := m.OpenStreamSync(ctx) 224 _, err := m.OpenStreamSync(ctx) 252 _, err := m.OpenStreamSync(context.Background()) 258 _, err := m.OpenStreamSync(context.Background()) 265 _, err := m.OpenStreamSync(context.Background()) 326 _, err := m.OpenStreamSync(context.Background()) 383 _, err := m.OpenStreamSync(context.Background()) 389 _, err := m.OpenStreamSync(context.Background()) [all …]
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 127 _, err := m.OpenStreamSync(ctx) 136 str, err := m.OpenStreamSync(context.Background()) 153 _, err := m.OpenStreamSync(ctx) 214 _, err := m.OpenStreamSync(ctx) 242 _, err := m.OpenStreamSync(context.Background()) 248 _, err := m.OpenStreamSync(context.Background()) 255 _, err := m.OpenStreamSync(context.Background()) 316 _, err := m.OpenStreamSync(context.Background()) 373 _, err := m.OpenStreamSync(context.Background()) 379 _, err := m.OpenStreamSync(context.Background()) [all …]
|
H A D | mock_stream_manager_test.go | 155 func (m *MockStreamManager) OpenStreamSync(arg0 context.Context) (Stream, error) { func 164 func (mr *MockStreamManagerMockRecorder) OpenStreamSync(arg0 interface{}) *gomock.Call { func 166 …thodType(mr.mock, "OpenStreamSync", reflect.TypeOf((*MockStreamManager)(nil).OpenStreamSync), arg0)
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 137 _, err := m.OpenStreamSync(ctx) 146 str, err := m.OpenStreamSync(context.Background()) 163 _, err := m.OpenStreamSync(ctx) 224 _, err := m.OpenStreamSync(ctx) 252 _, err := m.OpenStreamSync(context.Background()) 258 _, err := m.OpenStreamSync(context.Background()) 265 _, err := m.OpenStreamSync(context.Background()) 326 _, err := m.OpenStreamSync(context.Background()) 383 _, err := m.OpenStreamSync(context.Background()) 389 _, err := m.OpenStreamSync(context.Background()) [all …]
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_outgoing_generic_test.go | 137 _, err := m.OpenStreamSync(ctx) 146 str, err := m.OpenStreamSync(context.Background()) 163 _, err := m.OpenStreamSync(ctx) 224 _, err := m.OpenStreamSync(ctx) 252 _, err := m.OpenStreamSync(context.Background()) 258 _, err := m.OpenStreamSync(context.Background()) 265 _, err := m.OpenStreamSync(context.Background()) 326 _, err := m.OpenStreamSync(context.Background()) 383 _, err := m.OpenStreamSync(context.Background()) 389 _, err := m.OpenStreamSync(context.Background()) [all …]
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 158 session.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr).MaxTimes(1) 219 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 242 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 280 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 378 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 412 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 439 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 458 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 475 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 501 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil)
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 158 session.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr).MaxTimes(1) 219 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 242 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 280 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 378 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 412 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 439 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 458 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 475 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 501 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil)
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/quic/gquic-go/ |
H A D | streams_map.go | 127 func (m *streamsMap) OpenStreamSync() (Stream, error) { func 128 return m.outgoingBidiStreams.OpenStreamSync() 136 return m.outgoingUniStreams.OpenStreamSync()
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/quic/gquic-go/ |
H A D | streams_map.go | 127 func (m *streamsMap) OpenStreamSync() (Stream, error) { func 128 return m.outgoingBidiStreams.OpenStreamSync() 136 return m.outgoingUniStreams.OpenStreamSync()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 208 sess.EXPECT().OpenStreamSync(gomock.Any()).Return(nil, errors.New("done")) 469 sess.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr) 480 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 497 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 517 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 629 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 658 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 681 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 698 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 713 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) [all …]
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 208 sess.EXPECT().OpenStreamSync(gomock.Any()).Return(nil, errors.New("done")) 469 sess.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr) 480 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 497 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 517 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 629 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 658 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 681 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 698 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 713 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) [all …]
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 208 sess.EXPECT().OpenStreamSync(gomock.Any()).Return(nil, errors.New("done")) 469 sess.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr) 480 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 497 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 517 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 629 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 658 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 681 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 698 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 713 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) [all …]
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 208 sess.EXPECT().OpenStreamSync(gomock.Any()).Return(nil, errors.New("done")) 469 sess.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr) 480 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 497 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 517 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 629 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 658 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 681 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 698 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 713 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) [all …]
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/http3/ |
H A D | client_test.go | 208 sess.EXPECT().OpenStreamSync(gomock.Any()).Return(nil, errors.New("done")) 469 sess.EXPECT().OpenStreamSync(context.Background()).Return(nil, testErr) 480 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 497 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 517 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil), 629 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 658 sess.EXPECT().OpenStreamSync(ctx).Return(str, nil) 681 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 698 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) 713 sess.EXPECT().OpenStreamSync(context.Background()).Return(str, nil) [all …]
|
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map.go | 92 func (m *streamsMap) OpenStreamSync() (Stream, error) { func 93 return m.outgoingBidiStreams.OpenStreamSync() 101 return m.outgoingUniStreams.OpenStreamSync()
|
H A D | streams_map_outgoing_generic_test.go | 115 str, err := m.OpenStreamSync() 134 str, err := m.OpenStreamSync() 151 _, err := m.OpenStreamSync()
|
H A D | mock_stream_manager_test.go | 155 func (m *MockStreamManager) OpenStreamSync() (Stream, error) { func 164 func (mr *MockStreamManagerMockRecorder) OpenStreamSync() *gomock.Call { func 166 …WithMethodType(mr.mock, "OpenStreamSync", reflect.TypeOf((*MockStreamManager)(nil).OpenStreamSync))
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/internal/mocks/quic/ |
H A D | early_session.go | 156 func (m *MockEarlySession) OpenStreamSync(arg0 context.Context) (quic.Stream, error) { func 165 func (mr *MockEarlySessionMockRecorder) OpenStreamSync(arg0 interface{}) *gomock.Call { func 167 …ethodType(mr.mock, "OpenStreamSync", reflect.TypeOf((*MockEarlySession)(nil).OpenStreamSync), arg0)
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/internal/mocks/quic/ |
H A D | early_session.go | 156 func (m *MockEarlySession) OpenStreamSync(arg0 context.Context) (quic.Stream, error) { func 165 func (mr *MockEarlySessionMockRecorder) OpenStreamSync(arg0 interface{}) *gomock.Call { func 167 …ethodType(mr.mock, "OpenStreamSync", reflect.TypeOf((*MockEarlySession)(nil).OpenStreamSync), arg0)
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/osp/go/ |
H A D | client.go | 19 stream, err := session.OpenStreamSync()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/osp/go/ |
H A D | client.go | 19 stream, err := session.OpenStreamSync()
|