Home
last modified time | relevance | path

Searched refs:OpenStreamSync (Results 1 – 25 of 192) sorted by relevance

12345678

/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_outgoing_generic_test.go127 _, 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 Dmock_stream_manager_test.go155 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 Dstreams_map_outgoing_generic_test.go137 _, 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 Dstreams_map_outgoing_generic_test.go137 _, 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 Dstreams_map_outgoing_generic_test.go137 _, 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 Dstreams_map_outgoing_generic_test.go127 _, 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 Dmock_stream_manager_test.go155 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 Dstreams_map_outgoing_generic_test.go137 _, 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 Dstreams_map_outgoing_generic_test.go137 _, 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 Dclient_test.go158 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 Dclient_test.go158 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 Dstreams_map.go127 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 Dstreams_map.go127 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 Dclient_test.go208 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 Dclient_test.go208 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 Dclient_test.go208 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 Dclient_test.go208 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 Dclient_test.go208 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 Dstreams_map.go92 func (m *streamsMap) OpenStreamSync() (Stream, error) { func
93 return m.outgoingBidiStreams.OpenStreamSync()
101 return m.outgoingUniStreams.OpenStreamSync()
H A Dstreams_map_outgoing_generic_test.go115 str, err := m.OpenStreamSync()
134 str, err := m.OpenStreamSync()
151 _, err := m.OpenStreamSync()
H A Dmock_stream_manager_test.go155 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 Dearly_session.go156 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 Dearly_session.go156 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 Dclient.go19 stream, err := session.OpenStreamSync()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/osp/go/
H A Dclient.go19 stream, err := session.OpenStreamSync()

12345678