Home
last modified time | relevance | path

Searched refs:receiveStreamI (Results 1 – 25 of 88) sorted by relevance

1234

/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go19 streams map[protocol.StreamNum]receiveStreamI
29 newStream func(protocol.StreamNum) receiveStreamI
36 newStream func(protocol.StreamNum) receiveStreamI, argument
42 streams: make(map[protocol.StreamNum]receiveStreamI),
53 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
63 var str receiveStreamI
96 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
109 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
H A Dstreams_map.go96 func(num protocol.StreamNum) receiveStreamI {
153 func (m *streamsMap) GetOrOpenReceiveStream(id protocol.StreamID) (receiveStreamI, error) {
161 func (m *streamsMap) getOrOpenReceiveStream(id protocol.StreamID) (receiveStreamI, error) {
172 var str receiveStreamI
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go19 streams map[protocol.StreamNum]receiveStreamI
29 newStream func(protocol.StreamNum) receiveStreamI
36 newStream func(protocol.StreamNum) receiveStreamI, argument
42 streams: make(map[protocol.StreamNum]receiveStreamI),
53 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
63 var str receiveStreamI
96 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
109 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
H A Dstreams_map.go96 func(num protocol.StreamNum) receiveStreamI {
153 func (m *streamsMap) GetOrOpenReceiveStream(id protocol.StreamID) (receiveStreamI, error) {
161 func (m *streamsMap) getOrOpenReceiveStream(id protocol.StreamID) (receiveStreamI, error) {
172 var str receiveStreamI
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/
H A Dstreams_map_incoming_uni.go19 streams map[protocol.StreamNum]receiveStreamI
29 newStream func(protocol.StreamNum) receiveStreamI
37 newStream func(protocol.StreamNum) receiveStreamI, argument
43 streams: make(map[protocol.StreamNum]receiveStreamI),
54 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
58 var str receiveStreamI
91 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
104 var s receiveStreamI
H A Dstreams_map.go97 func(num protocol.StreamNum) receiveStreamI {
154 func (m *streamsMap) GetOrOpenReceiveStream(id protocol.StreamID) (receiveStreamI, error) {
162 func (m *streamsMap) getOrOpenReceiveStream(id protocol.StreamID) (receiveStreamI, error) {
173 var str receiveStreamI
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/
H A Dstreams_map_incoming_uni.go19 streams map[protocol.StreamNum]receiveStreamI
29 newStream func(protocol.StreamNum) receiveStreamI
37 newStream func(protocol.StreamNum) receiveStreamI, argument
43 streams: make(map[protocol.StreamNum]receiveStreamI),
54 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
58 var str receiveStreamI
91 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
104 var s receiveStreamI
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go19 streams map[protocol.StreamNum]receiveStreamI
29 newStream func(protocol.StreamNum) receiveStreamI
36 newStream func(protocol.StreamNum) receiveStreamI, argument
42 streams: make(map[protocol.StreamNum]receiveStreamI),
53 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
63 var str receiveStreamI
96 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
109 var s receiveStreamI
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go19 streams map[protocol.StreamID]receiveStreamI
29 newStream func(protocol.StreamID) receiveStreamI
40 newStream func(protocol.StreamID) receiveStreamI, argument
43 streams: make(map[protocol.StreamID]receiveStreamI),
56 func (m *incomingUniStreamsMap) AcceptStream() (receiveStreamI, error) {
61 var str receiveStreamI
85 func (m *incomingUniStreamsMap) GetOrOpenStream(id protocol.StreamID) (receiveStreamI, error) {
95 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
/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_incoming_uni.go19 streams map[protocol.StreamID]receiveStreamI
26 newStream func(protocol.StreamID) receiveStreamI
37 newStream func(protocol.StreamID) receiveStreamI, argument
40 streams: make(map[protocol.StreamID]receiveStreamI),
51 func (m *incomingUniStreamsMap) AcceptStream() (receiveStreamI, error) {
55 var str receiveStreamI
71 func (m *incomingUniStreamsMap) GetOrOpenStream(id protocol.StreamID) (receiveStreamI, error) {
/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_incoming_uni.go19 streams map[protocol.StreamID]receiveStreamI
26 newStream func(protocol.StreamID) receiveStreamI
37 newStream func(protocol.StreamID) receiveStreamI, argument
40 streams: make(map[protocol.StreamID]receiveStreamI),
51 func (m *incomingUniStreamsMap) AcceptStream() (receiveStreamI, error) {
55 var str receiveStreamI
71 func (m *incomingUniStreamsMap) GetOrOpenStream(id protocol.StreamID) (receiveStreamI, error) {
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go18 stream receiveStreamI
33 newStream func(protocol.StreamNum) receiveStreamI
40 newStream func(protocol.StreamNum) receiveStreamI, argument
56 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
98 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
111 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go18 stream receiveStreamI
33 newStream func(protocol.StreamNum) receiveStreamI
40 newStream func(protocol.StreamNum) receiveStreamI, argument
56 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
98 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
111 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go18 stream receiveStreamI
33 newStream func(protocol.StreamNum) receiveStreamI
40 newStream func(protocol.StreamNum) receiveStreamI, argument
56 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
98 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
111 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go18 stream receiveStreamI
33 newStream func(protocol.StreamNum) receiveStreamI
40 newStream func(protocol.StreamNum) receiveStreamI, argument
56 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
98 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
111 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go18 stream receiveStreamI
33 newStream func(protocol.StreamNum) receiveStreamI
40 newStream func(protocol.StreamNum) receiveStreamI, argument
56 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
98 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
111 var s receiveStreamI
H A Dmock_stream_getter_test.go38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) {
41 ret0, _ := ret[0].(receiveStreamI)
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/
H A Dstreams_map_incoming_uni.go18 stream receiveStreamI
33 newStream func(protocol.StreamNum) receiveStreamI
40 newStream func(protocol.StreamNum) receiveStreamI, argument
56 func (m *incomingUniStreamsMap) AcceptStream(ctx context.Context) (receiveStreamI, error) {
98 func (m *incomingUniStreamsMap) GetOrOpenStream(num protocol.StreamNum) (receiveStreamI, error) {
111 var s receiveStreamI

1234