Searched refs:toDeliver (Results 1 – 11 of 11) sorted by relevance
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p/p2p/net/mock/ |
H A D | mock_stream.go | 30 toDeliver chan *transportObject member 68 toDeliver: make(chan *transportObject), 89 case s.toDeliver <- &transportObject{msg: cpy, arrivalTime: t}: 278 case o := <-s.toDeliver:
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 350 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 351 defer close(toDeliver) 369 case toDeliver <- q[0]:
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 351 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 352 defer close(toDeliver) 370 case toDeliver <- q[0]:
|
/dports/www/grafana8/grafana-8.3.6/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 351 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 352 defer close(toDeliver) 370 case toDeliver <- q[0]:
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 351 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 352 defer close(toDeliver) 370 case toDeliver <- q[0]:
|
/dports/dns/blocky/blocky-0.17/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 350 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 351 defer close(toDeliver) 369 case toDeliver <- q[0]:
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 351 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 352 defer close(toDeliver) 370 case toDeliver <- q[0]:
|
/dports/sysutils/restic/restic-0.12.1/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 350 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 351 defer close(toDeliver) 369 case toDeliver <- q[0]:
|
/dports/net/storj/storj-1.45.3/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 350 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 351 defer close(toDeliver) 369 case toDeliver <- q[0]:
|
/dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/golang.org/x/tools/internal/jsonrpc2_v2/ |
H A D | conn.go | 350 …ue(ctx context.Context, preempter Preempter, fromRead <-chan *incoming, toDeliver chan<- *incoming… 351 defer close(toDeliver) 369 case toDeliver <- q[0]:
|
/dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/http/ |
H A D | HttpSession.java | 1293 final List<Packet> toDeliver = deliverable.getPackets(); in getPackets() local 1294 if (toDeliver != null) { in getPackets() 1295 packets.addAll(toDeliver); in getPackets()
|