Home
last modified time | relevance | path

Searched refs:subscribe (Results 1 - 25 of 55) sorted by relevance

123

/third_party/typescript/tests/baselines/reference/
H A DgenericCallbacksAndClassHierarchy.js4 subscribe(callback: (newValue: T) => void ): any;
20 v.subscribe(f);
21 v.subscribe((newValue: A<T>) => { });
71 v.subscribe(f);
72 v.subscribe(function (newValue) { });
H A DsymbolProperty61.js13 subscribe(next: (val: T) => void) {
23 [Symbol.obs]: () => { subscribe(next: (val: T) => void): void }
39 subscribe(next) {
62 subscribe(next: (val: T) => void): void;
H A DobservableInferenceCanBeMade.js10 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
16 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
/third_party/ltp/utils/sctp/func_tests/
H A Dtest_sctp_sendrecvmsg.c84 struct sctp_event_subscribe subscribe; in main() local
137 memset(&subscribe, 0, sizeof(subscribe)); in main()
138 subscribe.sctp_data_io_event = 1; in main()
139 subscribe.sctp_association_event = 1; in main()
140 subscribe.sctp_send_failure_event = 1; in main()
141 test_setsockopt(sk1, SCTP_EVENTS, &subscribe, sizeof(subscribe)); in main()
142 test_setsockopt(sk2, SCTP_EVENTS, &subscribe, sizeof(subscribe)); in main()
[all...]
H A Dtest_timetolive.c110 struct sctp_event_subscribe subscribe; in main() local
165 memset(&subscribe, 0, sizeof(subscribe)); in main()
166 subscribe.sctp_data_io_event = 1; in main()
167 subscribe.sctp_association_event = 1; in main()
168 subscribe.sctp_send_failure_event = 1; in main()
169 test_setsockopt(sk1, SCTP_EVENTS, &subscribe, sizeof(subscribe)); in main()
170 test_setsockopt(sk2, SCTP_EVENTS, &subscribe, sizeof(subscribe)); in main()
[all...]
H A Dtest_sockopt.c88 struct sctp_event_subscribe subscribe; in main() local
302 optlen = sizeof(subscribe); in main()
303 test_getsockopt(udp_svr_sk, SCTP_EVENTS, &subscribe, &optlen); in main()
306 optlen = sizeof(subscribe); in main()
307 test_getsockopt(udp_clt_sk, SCTP_EVENTS, &subscribe, &optlen); in main()
312 memset(&subscribe, 0, sizeof(struct sctp_event_subscribe)); in main()
313 test_setsockopt(udp_svr_sk, SCTP_EVENTS, &subscribe, in main()
314 sizeof(subscribe)); in main()
315 test_setsockopt(udp_clt_sk, SCTP_EVENTS, &subscribe, in main()
316 sizeof(subscribe)); in main()
[all...]
/third_party/node/test/parallel/
H A Dtest-diagnostics-channel-pub-sub.js26 dc.subscribe(name, subscriber);
43 dc.subscribe(name, null);
47 // will be no more weakref to incRef if another subscribe happens while the
49 channel.subscribe(subscriber);
51 channel.subscribe(subscriber);
H A Dtest-diagnostics-channel-memory-leak.js9 const { subscribe, unsubscribe } = require('diagnostics_channel');
16 subscribe(String(i), noop);
H A Dtest-diagnostics-channel-safe-subscriber-errors.js19 channel.subscribe(common.mustCall((message, name) => {
24 channel.subscribe(common.mustCall());
H A Dtest-diagnostics-channel-object-channel-pub-sub.js28 channel.subscribe(subscriber);
45 channel.subscribe(null);
H A Dtest-diagnostics-channel-http-server-start.js13 dc.subscribe('http.server.request.start', common.mustCall((message) => {
20 dc.subscribe('http.server.response.finish', common.mustCall((message) => {
H A Dtest-diagnostics-channel-symbol-named.js17 channel.subscribe(common.mustCall((message, name) => {
H A Dtest-diagnostics-channel-tracing-channel-sync-error.js28 channel.subscribe(handlers);
H A Dtest-diagnostics-channel-tracing-channel-async-error.js28 channel.subscribe(handlers);
H A Dtest-diagnostics-channel-tracing-channel-sync.js30 channel.subscribe(handlers);
H A Dtest-diagnostics-channel-tracing-channel-async.js33 channel.subscribe(handlers);
/third_party/node/lib/
H A Ddiagnostics_channel.js96 subscribe(subscription) {
181 subscribe(subscription) {
183 this.subscribe(subscription);
223 function subscribe(name, subscription) { function
224 return channel(name).subscribe(subscription);
281 subscribe(handlers) {
285 this[name]?.subscribe(handlers[name]);
409 subscribe,
/third_party/ltp/utils/sctp/testlib/
H A Dsctputil.c337 struct sctp_event_subscribe subscribe; in test_enable_assoc_change() local
339 memset(&subscribe, 0, sizeof(subscribe)); in test_enable_assoc_change()
340 subscribe.sctp_data_io_event = 1; in test_enable_assoc_change()
341 subscribe.sctp_association_event = 1; in test_enable_assoc_change()
342 test_setsockopt(fd, SCTP_EVENTS, (char *)&subscribe, in test_enable_assoc_change()
343 sizeof(subscribe)); in test_enable_assoc_change()
/third_party/node/benchmark/diagnostics_channel/
H A Dhttp.js89 start.subscribe(onStart);
90 finish.subscribe(onFinish);
H A Dsubscribe.js16 channel.subscribe(noop);
H A Dpublish.js15 channel.subscribe(noop);
/third_party/ffmpeg/libavformat/
H A Dlibrtmp.c46 char *subscribe; member
149 if (ctx->subscribe) in rtmp_open()
150 av_bprintf(&ctx->filename, " subscribe=%s", ctx->subscribe); in rtmp_open()
274 {"rtmp_subscribe", "Name of live stream to subscribe to. Defaults to rtmp_playpath.", OFFSET(subscribe), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
/third_party/libwebsockets/lib/secure-streams/protocols/
H A Dss-mqtt.c66 if (!h->policy->u.mqtt.subscribe || wsi->mqtt->done_subscribe) in secstream_mqtt_subscribe()
76 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe, in secstream_mqtt_subscribe()
77 strlen(h->policy->u.mqtt.subscribe), &used_in, in secstream_mqtt_subscribe()
80 "%s, failed to expand MQTT subscribe" in secstream_mqtt_subscribe()
89 "%s, failed to allocate MQTT subscribe" in secstream_mqtt_subscribe()
98 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe, in secstream_mqtt_subscribe()
99 strlen(h->policy->u.mqtt.subscribe), &used_in, in secstream_mqtt_subscribe()
101 lwsl_err("%s, failed to expand MQTT subscribe topic\n", in secstream_mqtt_subscribe()
110 * The policy says to subscribe to something, and we in secstream_mqtt_subscribe()
128 lwsl_notice("%s: unable to subscribe", __func_ in secstream_mqtt_subscribe()
[all...]
/third_party/alsa-lib/src/control/
H A Dcontrol_ext.c66 static int snd_ctl_ext_subscribe_events(snd_ctl_t *handle, int subscribe) in snd_ctl_ext_subscribe_events() argument
70 if (subscribe < 0) in snd_ctl_ext_subscribe_events()
72 ext->subscribed = !!subscribe; in snd_ctl_ext_subscribe_events()
74 ext->callback->subscribe_events(ext, subscribe); in snd_ctl_ext_subscribe_events()
/third_party/pulseaudio/src/pulse/
H A Dpulseaudio.h32 #include <pulse/subscribe.h>
52 * \ref context.h, \ref stream.h, \ref introspect.h, \ref subscribe.h, \ref

Completed in 8 milliseconds

123