/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | streams_map_incoming_uni.go | 19 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 D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { 41 ret0, _ := ret[0].(receiveStreamI)
|
H A D | streams_map.go | 96 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 D | streams_map_incoming_uni.go | 19 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 D | mock_stream_getter_test.go | 38 func (m *MockStreamGetter) GetOrOpenReceiveStream(arg0 protocol.StreamID) (receiveStreamI, error) { 41 ret0, _ := ret[0].(receiveStreamI)
|
H A D | streams_map.go | 96 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 D | streams_map_incoming_uni.go | 19 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 D | streams_map.go | 97 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 D | streams_map_incoming_uni.go | 19 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 D | streams_map_incoming_uni.go | 19 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 D | streams_map_incoming_uni.go | 19 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 D | mock_stream_getter_test.go | 38 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 D | streams_map_incoming_uni.go | 19 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 D | streams_map_incoming_uni.go | 19 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 D | streams_map_incoming_uni.go | 18 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 D | mock_stream_getter_test.go | 38 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 D | streams_map_incoming_uni.go | 18 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 D | mock_stream_getter_test.go | 38 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 D | streams_map_incoming_uni.go | 18 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 D | mock_stream_getter_test.go | 38 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 D | streams_map_incoming_uni.go | 18 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 D | mock_stream_getter_test.go | 38 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 D | streams_map_incoming_uni.go | 18 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 D | mock_stream_getter_test.go | 38 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 D | streams_map_incoming_uni.go | 18 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
|