Home
last modified time | relevance | path

Searched refs:openSubscription (Results 1 – 25 of 53) sorted by relevance

123

/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 DwindowToggle.ts89 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 DwindowToggle.ts89 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 DwindowToggle.ts89 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 DwindowToggle.ts89 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 Dnats_test.go71 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 Dnats.go302 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 Dnats_test.go71 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 Dnats.go294 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 Dnats_test.go71 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 Dnats.go294 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 Dnats_test.go71 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 Dnats.go294 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 Dgcppubsub.go378 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 Dgcppubsub.go378 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 Dgcppubsub.go378 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 Dgcppubsub.go402 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 Dawssnssqs_test.go136 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 Dawssnssqs_test.go136 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 Dawssnssqs_test.go136 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 Dawssnssqs_test.go136 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 Dazuresb_test.go127 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 Dazuresb_test.go127 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 Dazuresb_test.go127 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 Dazuresb_test.go127 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 Dkafka_test.go106 …ds, err := openSubscription(localBrokerAddrs, MinimalConfig(), groupID, []string{dt.(*topic).topic…
111 …ds, err := openSubscription(localBrokerAddrs, MinimalConfig(), "unused-group", []string{"nonexiste…

123