Home
last modified time | relevance | path

Searched refs:_subscription (Results 1 – 25 of 57) sorted by relevance

123

/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/consumer/
H A Dgroup.py381 self._subscription.subscribe(topics=topics)
409 self._subscription.assign_from_user(partitions)
426 return self._subscription.assigned_partitions()
533 if self._subscription.is_assigned(partition):
719 self._subscription.pause(partition)
728 return self._subscription.paused_partitions()
740 self._subscription.resume(partition)
858 self._subscription.subscribe(topics=topics,
879 if self._subscription.subscription is None:
881 return self._subscription.subscription.copy()
[all …]
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/coordinator/
H A Dconsumer.py87 self._subscription = subscription
138 if self._subscription.subscription is None:
163 if self._subscription.subscribed_pattern:
175 if self._subscription.partitions_auto_assigned():
242 if self._subscription.listener:
278 if self._subscription.subscribed_pattern:
343 if self._subscription.listener:
353 self._subscription.reset_group_subscription()
381 if self._subscription.needs_fetch_committed_offsets:
567 if self._subscription.partitions_auto_assigned():
[all …]
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/
H A DTimeout.cs60 private SerialDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Timeout.TimeA
66 _subscription = new SerialDisposable(); in Run()
69 _subscription.Disposable = original; in Run()
78 return new CompositeDisposable(_subscription, timer); in Run()
149 private SerialDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Timeout.TimeR
158 _subscription = new SerialDisposable(); in Run()
162 _subscription.Disposable = original; in Run()
172 return new CompositeDisposable(_subscription, _timer); in Run()
290 private SerialDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Timeout._
298 _subscription = new SerialDisposable(); in Run()
[all …]
H A DGetEnumerator.cs22 private readonly SingleAssignmentDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.GetEnumerator
28 _subscription = new SingleAssignmentDisposable(); in GetEnumerator()
36 _subscription.Disposable = source.Subscribe/*Unsafe*/(this); in Run()
49 _subscription.Dispose(); in OnError()
56 _subscription.Dispose(); in OnCompleted()
90 _subscription.Dispose(); in Dispose()
H A DSkipUntil.cs60 private readonly SingleAssignmentDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.SkipUntil._.T
66 _subscription = new SingleAssignmentDisposable(); in T()
71 set { _subscription.Disposable = value; }
88 …_subscription.Dispose(); // We can't cancel the other stream yet, it may be on its way to dispatch… in OnCompleted()
96 private readonly SingleAssignmentDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.SkipUntil._.O
102 _subscription = new SingleAssignmentDisposable(); in O()
107 set { _subscription.Disposable = value; }
113 _subscription.Dispose(); in OnNext()
124 _subscription.Dispose(); in OnCompleted()
H A DTakeLast.cs62 private SingleAssignmentDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.TakeLast._
67 _subscription = new SingleAssignmentDisposable(); in Run()
70 _subscription.Disposable = _parent._source.SubscribeSafe(this); in Run()
72 return new CompositeDisposable(_subscription, _loop); in Run()
90 _subscription.Dispose(); in OnCompleted()
146 private SingleAssignmentDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.TakeLast.TakeLastImpl
152 _subscription = new SingleAssignmentDisposable(); in Run()
156 _subscription.Disposable = _parent._source.SubscribeSafe(this); in Run()
158 return new CompositeDisposable(_subscription, _loop); in Run()
176 _subscription.Dispose(); in OnCompleted()
H A DPushToPullAdapter.cs37 private readonly IDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.PushToPullSink
41 _subscription = subscription; in PushToPullSink()
65 _subscription.Dispose(); in MoveNext()
90 _subscription.Dispose(); in Dispose()
H A DCatch.cs102 private SerialDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Catch._
106 _subscription = new SerialDisposable(); in Run()
109 _subscription.Disposable = d1; in Run()
112 return _subscription; in Run()
138 _subscription.Disposable = d; in OnError()
H A DAmb.cs67 private readonly IDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Amb._.DecisionObserver
77 _subscription = subscription; in DecisionObserver()
90 _observer._disposable = _subscription; in OnNext()
107 _observer._disposable = _subscription; in OnError()
127 _observer._disposable = _subscription; in OnCompleted()
H A DSwitch.cs36 private IDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Switch._
51 _subscription = subscription; in Run()
54 return new CompositeDisposable(_subscription, _innerSubscription); in Run()
83 _subscription.Dispose(); in OnCompleted()
H A DTakeUntil.cs119 private readonly SingleAssignmentDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.TakeUntil._.O
125 _subscription = new SingleAssignmentDisposable(); in O()
130 set { _subscription.Disposable = value; }
156 _subscription.Dispose(); in OnCompleted()
H A DDelay.cs617 private SerialDisposable _subscription; field in System.Reactive.Linq.ObservableImpl.Delay._
624 _subscription = new SerialDisposable(); in Run()
632 … _subscription.Disposable = _parent._subscriptionDelay.SubscribeSafe(new SubscriptionDelay(this)); in Run()
635 return new CompositeDisposable(_subscription, _delays); in Run()
640 _subscription.Disposable = _parent._source.SubscribeSafe(this); in Start()
680 _subscription.Dispose(); in OnCompleted()
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Subjects/
H A DConnectableObservable.cs54 private IDisposable _subscription; field in System.Reactive.Subjects.ConnectableObservable.Connection
59 _subscription = subscription; in Connection()
66 if (_subscription != null) in Dispose()
68 _subscription.Dispose(); in Dispose()
69 _subscription = null; in Dispose()
/dports/devel/py-openstacksdk/openstacksdk-0.60.0/openstack/message/v2/
H A D_proxy.py16 from openstack.message.v2 import subscription as _subscription unknown
166 return self._create(_subscription.Subscription, queue_name=queue_name,
187 return self._list(_subscription.Subscription, **query)
200 subscription = self._get_resource(_subscription.Subscription,
203 return self._get(_subscription.Subscription, subscription)
221 subscription = self._get_resource(_subscription.Subscription, value,
223 return self._delete(_subscription.Subscription, subscription,
/dports/net/py-kafka-python/kafka-python-1.4.5/test/
H A Dtest_coordinator.py70 coordinator._subscription.subscribe(topics=['foobar'])
86 coordinator._subscription.subscribe(pattern='foo')
87 assert coordinator._subscription.subscription == set([])
102 assert coordinator._subscription.assignment == {}
118 coordinator._subscription.subscribe(topics=['foobar'])
132 coordinator._subscription.subscribe(
151 coordinator._subscription.subscribe(
193 coordinator._subscription.subscribe(topics=['foobar'])
201 coordinator._subscription.subscribe(topics=['foobar'])
213 assignment = coordinator._subscription.assignment
[all …]
/dports/devel/py-rx/Rx-3.2.0/rx/core/observer/
H A Dautodetachobserver.py20 self._subscription = SingleAssignmentDisposable()
49 self._subscription.disposable = value
55 self._subscription.dispose()
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Internal/
H A DTailRecursiveSink.cs18 private SerialDisposable _subscription; field in System.Reactive.TailRecursiveSink
27 _subscription = new SerialDisposable(); in Run()
45 …return new CompositeDisposable(_subscription, cancelable, Disposable.Create(() => _gate.Wait(Dispo… in Run()
142 _subscription.Disposable = d; in MoveNext()
/dports/devel/py-graphene/graphene-2.1.9/graphene/types/
H A Dschema.py66 self._subscription = subscription
87 return self.get_graphql_type(self._subscription)
162 self._subscription,
/dports/devel/py-graphql-core2/graphql-core-2.2.1/graphql/type/
H A Dschema.py88 self._subscription = subscription
116 return self._subscription
/dports/net-im/py-slixmpp/slixmpp-1.7.1/slixmpp/roster/
H A Ditem.py171 self['subscription'] = self._subscription()
183 self['subscription'] = self._subscription()
198 return self._subscription()
223 def _subscription(self): member in RosterItem
/dports/net-im/py-slixmpp/slixmpp-1.7.1/examples/
H A Dpubsub_events.py32 self.add_event_handler('pubsub_subscription', self._subscription)
78 def _subscription(self, msg): member in PubsubEvents
/dports/textproc/opensearch-dashboards/opensearch-dashboards-1.2.0-linux-x64/plugins/reportsDashboards/node_modules/@react-navigation/native/lib/commonjs/
H A DcreateNavigationAwareScrollable.js.map1 …_subscription","props","navigation","addListener","scrollableNode","getNode","isFocused","scrollTo…
/dports/textproc/opensearch-dashboards/opensearch-dashboards-1.2.0-linux-x64/plugins/reportsDashboards/node_modules/@react-navigation/native/lib/module/
H A DcreateNavigationAwareScrollable.js.map1 …_subscription","props","navigation","addListener","scrollableNode","getNode","isFocused","scrollTo…
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/media/streaming/
H A Dmedia_streaming_audio_track.cpp199 if (!_subscription) { in playPosition()
200 _subscription = Media::Player::Updated( in playPosition()
/dports/sysutils/py-salt/salt-3004.1/tests/integration/states/
H A Dtest_boto_sns.py306 for _subscription in ret:
308 self.assertDictContainsSubset(subscription, _subscription)

123