| /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/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/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | MonoAwaitStressTest.kt | 29 override fun subscribe(s: CoreSubscriber<in Int>) { in <lambda>() method
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | subscribe.py | 309 def subscribe(tensors, side_effects): function
|
| /external/ltp/utils/sctp/func_tests/ |
| D | test_sctp_sendrecvmsg.c | 84 struct sctp_event_subscribe subscribe; in main() local
|
| D | test_timetolive.c | 110 struct sctp_event_subscribe subscribe; in main() local
|
| D | test_sockopt.c | 88 struct sctp_event_subscribe subscribe; in main() local
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowWifiAwareManager.java | 55 protected void subscribe( in subscribe() method in ShadowWifiAwareManager
|
| /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/python/bumble/bumble/ |
| D | gatt_client.py | 162 async def subscribe(self, subscriber=None, prefer_notify=True): member in CharacteristicProxy
666 async def subscribe(self, characteristic, subscriber=None, prefer_notify=True): member in Client
|
| /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/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | SharedFlowScenarioTest.kt | 353 fun subscribe(id: String): TestJob { in <lambda>() method in kotlinx.coroutines.flow.SharedFlowScenarioTest
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 180 override fun subscribe(subscriber: Subscriber<in T>?) { in subscribe() method in FlowAsPublisher
|
| /external/tinyalsa_new/src/ |
| D | mixer_plugin.c | 167 int *subscribe) in mixer_plug_subscribe_events()
|
| D | mixer.c | 454 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 | 817 int mixer_subscribe_events(struct mixer *mixer, int subscribe) in mixer_subscribe_events()
|
| /external/python/python-api-core/google/api_core/ |
| D | grpc_helpers.py | 485 def subscribe(self, callback, try_to_connect=False): member in ChannelStub
|
| /external/rust/crates/tokio/src/sync/ |
| D | watch.rs | 938 pub fn subscribe(&self) -> Receiver<T> { in subscribe() method
|
| D | broadcast.rs | 601 pub fn subscribe(&self) -> Receiver<T> { in subscribe() method
|
| /external/libwebsockets/include/libwebsockets/ |
| D | lws-secure-streams-policy.h | 310 const char *subscribe; /* stream subscribes to this topic */ member
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 400 def subscribe(self, callback, try_to_connect=False): member in _Channel
|