| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Migration.kt | 155 public fun <T> Flow<T>.subscribe(): Unit = noImpl() in <lambda>() method
164 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit): Unit = noImpl() in <lambda>() method
173 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit, onError: suspend (Throwable) -> Unit… in <lambda>() method
|
| /external/robolectric-shadows/shadows/supportv4/src/main/java/org/robolectric/shadows/support/v4/ |
| D | ShadowMediaBrowserCompat.java | 108 protected void subscribe(@NonNull String parentId, @NonNull SubscriptionCallback callback) { in subscribe() method in ShadowMediaBrowserCompat
113 protected void subscribe( in subscribe() method in ShadowMediaBrowserCompat
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-ref_count.hpp | 63 void subscribe(Subscriber&& o) { in subscribe() function
77 void subscribe(Subscriber&& o) { in subscribe() function
|
| D | rx-subscribe.hpp | 87 auto subscribe(ArgN&&... an) in subscribe() function
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | ReactorFlow.kt | 35 override fun subscribe(subscriber: CoreSubscriber<in T>?) { in asFlux() method in kotlinx.coroutines.reactor.FlowAsFlux
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | subscribe.py | 313 def subscribe(tensors, side_effects): function
|
| /external/ltp/utils/sctp/func_tests/ |
| D | test_sctp_sendrecvmsg.c | 83 struct sctp_event_subscribe subscribe; in main() local
|
| D | test_timetolive.c | 109 struct sctp_event_subscribe subscribe; in main() local
|
| D | test_sockopt.c | 87 struct sctp_event_subscribe subscribe; in main() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | CancellableContinuationJvmTest.kt | 71 public fun subscribe() { in subscribe() method in kotlinx.coroutines.CancellableContinuationJvmTest.BlockingSource
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel.py | 29 def subscribe(self, callback, try_to_connect=False): member in TestingChannel
|
| /external/ltp/utils/sctp/testlib/ |
| D | sctputil.c | 337 struct sctp_event_subscribe subscribe; in test_enable_assoc_change() local
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | implementations.py | 77 def subscribe(self, callback, try_to_connect=None): member in Channel
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 175 override fun subscribe(subscriber: Subscriber<in T>?) { in subscribe() method in FlowAsPublisher
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | SharedFlowScenarioTest.kt | 353 fun subscribe(id: String): TestJob { in <lambda>() method
|
| /external/tinyalsa_new/src/ |
| D | mixer_plugin.c | 165 int *subscribe) in mixer_plug_subscribe_events()
|
| D | mixer.c | 453 int mixer_subscribe_events(struct mixer *mixer, int subscribe) in mixer_subscribe_events()
|
| /external/tinyalsa/ |
| D | mixer_plugin.c | 162 int *subscribe) in mixer_plug_subscribe_events()
|
| D | mixer.c | 814 int mixer_subscribe_events(struct mixer *mixer, int subscribe) in mixer_subscribe_events()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 242 auto subscribe(ArgN&&... an) const in subscribe() function in rxcpp::blocking_observable
437 void subscribe() { in subscribe() function
652 auto subscribe(ArgN&&... an) const in subscribe() function in rxcpp::observable
|
| D | rx-notification.hpp | 26 inline long subscribe() const { in subscribe() function in rxcpp::notifications::subscription
|
| /external/libwebsockets/include/libwebsockets/ |
| D | lws-secure-streams-policy.h | 213 const char *subscribe; /* stream subscribes to this topic */ member
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 553 pub fn subscribe(&self) -> Receiver<T> { in subscribe() method
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 400 def subscribe(self, callback, try_to_connect=False): member in _Channel
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-test.hpp | 402 static rxn::subscription subscribe(long subscribe, long unsubscribe) { in subscribe() function
|