/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/ |
H A D | windowToggle.ts | 89 private openSubscription: Subscription; property in WindowToggleSubscriber 95 this.add(this.openSubscription = subscribeToResult(this, openings, openings as any)); 194 if (inner !== this.openSubscription) {
|
/dports/misc/netron/node_modules/rxjs/src/internal/operators/ |
H A D | windowToggle.ts | 89 private openSubscription: Subscription; property in WindowToggleSubscriber 95 this.add(this.openSubscription = subscribeToResult(this, openings, openings as any)); 194 if (inner !== this.openSubscription) {
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/ |
H A D | windowToggle.ts | 89 private openSubscription: Subscription; property in WindowToggleSubscriber 95 this.add(this.openSubscription = subscribeToResult(this, openings, openings as any)); 194 if (inner !== this.openSubscription) {
|
/dports/textproc/write-good/write-good-1.0.8/node_modules/rxjs/src/internal/operators/ |
H A D | windowToggle.ts | 89 private openSubscription: Subscription; property in WindowToggleSubscriber 95 this.add(this.openSubscription = subscribeToResult(this, openings, openings as any)); 194 if (inner !== this.openSubscription) {
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/natspubsub/ |
H A D | nats_test.go | 71 ds, err := openSubscription(h.nc, testName, nil) 85 ds, err := openSubscription(h.nc, testName, &SubscriptionOptions{Queue: testName}) 269 ds, err := openSubscription(h.nc, "bar", nil) 302 qs, err := openSubscription(h.nc, "bar", &SubscriptionOptions{Queue: t.Name()})
|
H A D | nats.go | 302 ds, err := openSubscription(nc, subject, opts) 309 func openSubscription(nc *nats.Conn, subject string, opts *SubscriptionOptions) (driver.Subscriptio… func
|
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/natspubsub/ |
H A D | nats_test.go | 71 ds, err := openSubscription(h.nc, testName, nil) 85 ds, err := openSubscription(h.nc, testName, &SubscriptionOptions{Queue: testName}) 265 ds, err := openSubscription(h.nc, "bar", nil) 298 qs, err := openSubscription(h.nc, "bar", &SubscriptionOptions{Queue: t.Name()})
|
H A D | nats.go | 294 ds, err := openSubscription(nc, subject, opts) 301 func openSubscription(nc *nats.Conn, subject string, opts *SubscriptionOptions) (driver.Subscriptio… func
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/natspubsub/ |
H A D | nats_test.go | 71 ds, err := openSubscription(h.nc, testName, nil) 85 ds, err := openSubscription(h.nc, testName, &SubscriptionOptions{Queue: testName}) 265 ds, err := openSubscription(h.nc, "bar", nil) 298 qs, err := openSubscription(h.nc, "bar", &SubscriptionOptions{Queue: t.Name()})
|
H A D | nats.go | 294 ds, err := openSubscription(nc, subject, opts) 301 func openSubscription(nc *nats.Conn, subject string, opts *SubscriptionOptions) (driver.Subscriptio… func
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/natspubsub/ |
H A D | nats_test.go | 71 ds, err := openSubscription(h.nc, testName, nil) 85 ds, err := openSubscription(h.nc, testName, &SubscriptionOptions{Queue: testName}) 265 ds, err := openSubscription(h.nc, "bar", nil) 298 qs, err := openSubscription(h.nc, "bar", &SubscriptionOptions{Queue: t.Name()})
|
H A D | nats.go | 294 ds, err := openSubscription(nc, subject, opts) 301 func openSubscription(nc *nats.Conn, subject string, opts *SubscriptionOptions) (driver.Subscriptio… func
|
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/gcppubsub/ |
H A D | gcppubsub.go | 378 return pubsub.NewSubscription(openSubscription(client, path), nil, ackBatcherOpts) 391 return pubsub.NewSubscription(openSubscription(client, subscriptionPath), nil, ackBatcherOpts), nil 395 func openSubscription(client *raw.SubscriberClient, subscriptionPath string) driver.Subscription { func
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/gcppubsub/ |
H A D | gcppubsub.go | 378 return pubsub.NewSubscription(openSubscription(client, path), nil, ackBatcherOpts) 391 return pubsub.NewSubscription(openSubscription(client, subscriptionPath), nil, ackBatcherOpts), nil 395 func openSubscription(client *raw.SubscriberClient, subscriptionPath string) driver.Subscription { func
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/gcppubsub/ |
H A D | gcppubsub.go | 378 return pubsub.NewSubscription(openSubscription(client, path), nil, ackBatcherOpts) 391 return pubsub.NewSubscription(openSubscription(client, subscriptionPath), nil, ackBatcherOpts), nil 395 func openSubscription(client *raw.SubscriberClient, subscriptionPath string) driver.Subscription { func
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/gcppubsub/ |
H A D | gcppubsub.go | 402 return pubsub.NewSubscription(openSubscription(client, path), nil, ackBatcherOpts) 415 return pubsub.NewSubscription(openSubscription(client, subscriptionPath), nil, ackBatcherOpts), nil 419 func openSubscription(client *raw.SubscriberClient, subscriptionPath string) driver.Subscription { func
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/awssnssqs/ |
H A D | awssnssqs_test.go | 136 ds = openSubscription(ctx, sess, qURL, nil) 162 return openSubscription(ctx, sess, qURL, nil), func() {}, nil 212 return openSubscription(ctx, h.sess, fakeSubscriptionQueueURL, nil), func() {}, nil
|
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/awssnssqs/ |
H A D | awssnssqs_test.go | 136 ds = openSubscription(ctx, sess, qURL, nil) 162 return openSubscription(ctx, sess, qURL, nil), func() {}, nil 212 return openSubscription(ctx, h.sess, fakeSubscriptionQueueURL, nil), nil
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/awssnssqs/ |
H A D | awssnssqs_test.go | 136 ds = openSubscription(ctx, sess, qURL, nil) 162 return openSubscription(ctx, sess, qURL, nil), func() {}, nil 212 return openSubscription(ctx, h.sess, fakeSubscriptionQueueURL, nil), func() {}, nil
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/awssnssqs/ |
H A D | awssnssqs_test.go | 136 ds = openSubscription(ctx, sess, qURL, nil) 162 return openSubscription(ctx, sess, qURL, nil), func() {}, nil 212 return openSubscription(ctx, h.sess, fakeSubscriptionQueueURL, nil), func() {}, nil
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/azuresb/ |
H A D | azuresb_test.go | 127 ds, err = openSubscription(ctx, h.ns, t.sbTopic, sbSub, &sopts) 149 sub, err := openSubscription(ctx, h.ns, sbTopic, sbSub, nil)
|
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/azuresb/ |
H A D | azuresb_test.go | 127 ds, err = openSubscription(ctx, h.ns, t.sbTopic, sbSub, &sopts) 142 return openSubscription(ctx, h.ns, sbTopic, sbSub, nil)
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/azuresb/ |
H A D | azuresb_test.go | 127 ds, err = openSubscription(ctx, h.ns, t.sbTopic, sbSub, &sopts) 149 sub, err := openSubscription(ctx, h.ns, sbTopic, sbSub, nil)
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/azuresb/ |
H A D | azuresb_test.go | 127 ds, err = openSubscription(ctx, h.ns, t.sbTopic, sbSub, &sopts) 149 sub, err := openSubscription(ctx, h.ns, sbTopic, sbSub, nil)
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/kafkapubsub/ |
H A D | kafka_test.go | 106 …ds, err := openSubscription(localBrokerAddrs, MinimalConfig(), groupID, []string{dt.(*topic).topic… 111 …ds, err := openSubscription(localBrokerAddrs, MinimalConfig(), "unused-group", []string{"nonexiste…
|