| /third_party/typescript/tests/baselines/reference/ |
| D | genericCallbacksAndClassHierarchy.types | 6 subscribe(callback: (newValue: T) => void ): any;
7 >subscribe : (callback: (newValue: T) => void) => any
46 v.subscribe(f);
47 >v.subscribe(f) : any
48 >v.subscribe : (callback: (newValue: A<T>) => void) => any
50 >subscribe : (callback: (newValue: A<T>) => void) => any
53 v.subscribe((newValue: A<T>) => { });
54 >v.subscribe((newValue: A<T>) => { }) : any
55 >v.subscribe : (callback: (newValue: A<T>) => void) => any
57 >subscribe : (callback: (newValue: A<T>) => void) => any
|
| D | genericCallbacksAndClassHierarchy.symbols | 9 subscribe(callback: (newValue: T) => void ): any;
10 >subscribe : Symbol(I.subscribe, Decl(genericCallbacksAndClassHierarchy.ts, 1, 27))
64 v.subscribe(f);
65 >v.subscribe : Symbol(I.subscribe, Decl(genericCallbacksAndClassHierarchy.ts, 1, 27))
67 >subscribe : Symbol(I.subscribe, Decl(genericCallbacksAndClassHierarchy.ts, 1, 27))
70 v.subscribe((newValue: A<T>) => { });
71 >v.subscribe : Symbol(I.subscribe, Decl(genericCallbacksAndClassHierarchy.ts, 1, 27))
73 >subscribe : Symbol(I.subscribe, Decl(genericCallbacksAndClassHierarchy.ts, 1, 27))
|
| D | genericCallbacksAndClassHierarchy.js | 4 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) { });
|
| D | observableInferenceCanBeMade.symbols | 34 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
35 >subscribe : Symbol(Subscribable.subscribe, Decl(observableInferenceCanBeMade.ts, 7, 27))
57 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
58 >subscribe : Symbol(Observable.subscribe, Decl(observableInferenceCanBeMade.ts, 13, 56))
|
| D | observableInferenceCanBeMade.types | 16 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
17 >subscribe : (next?: ((value: T) => void) | undefined, error?: ((error: any) => void) | undefined, …
31 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
32 >subscribe : (next?: ((value: T) => void) | undefined, error?: ((error: any) => void) | undefined, …
|
| D | observableInferenceCanBeMade.js | 10 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/ |
| D | test_sctp_sendrecvmsg.c | 84 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()
|
| D | test_timetolive.c | 110 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()
|
| D | test_sockopt.c | 88 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/typescript/tests/cases/compiler/ |
| D | genericCallbacksAndClassHierarchy.ts | 3 subscribe(callback: (newValue: T) => void ): any; method
19 v.subscribe(f);
20 v.subscribe((newValue: A<T>) => { });
|
| D | observableInferenceCanBeMade.ts | 11 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void;
17 subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): void; method in Observable
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_connectivity_test.py | 65 channel.subscribe(callback.update, try_to_connect=False)
67 channel.subscribe(callback.update, try_to_connect=True)
98 channel.subscribe(first_callback.update, try_to_connect=False)
105 channel.subscribe(second_callback.update, try_to_connect=True)
142 channel.subscribe(callback.update, try_to_connect=True)
|
| /third_party/ltp/utils/sctp/testlib/ |
| D | sctputil.c | 337 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/lib/ |
| D | diagnostics_channel.js | 25 subscribe(subscription) { method in ActiveChannel
78 subscribe(subscription) { method in Channel
81 this.subscribe(subscription);
|
| /third_party/node/doc/api/ |
| D | diagnostics_channel.md | 43 channel.subscribe((message, name) => {
137 #### `channel.subscribe(onMessage)`
143 Register a message handler to subscribe to this channel. This message handler
152 channel.subscribe((message, name) => {
172 [`channel.subscribe(onMessage)`][].
183 channel.subscribe(onMessage);
189 [`channel.subscribe(onMessage)`]: #diagnostics_channel_channel_subscribe_onmessage
|
| /third_party/libsnd/docs/ |
| D | lists.md | 14 [Subscribe](mailto:libsndfile-announce-request@mega-nerd.com?subject=subscribe)
18 [Subscribe](mailto:libsndfile-devel-request@mega-nerd.com?subject=subscribe)
22 [Subscribe](mailto:libsndfile-users-request@mega-nerd.com?subject=subscribe)
|
| /third_party/node/test/parallel/ |
| D | test-diagnostics-channel-safe-subscriber-errors.js | 19 channel.subscribe(common.mustCall((message, name) => {
24 channel.subscribe(common.mustCall());
|
| D | test-diagnostics-channel-object-channel-pub-sub.js | 28 channel.subscribe(subscriber);
45 channel.subscribe(null);
|
| D | test-diagnostics-channel-http-server-start.js | 16 incomingStartChannel.subscribe(common.mustCall((message) => {
23 outgoingFinishChannel.subscribe(common.mustCall((message) => {
|
| /third_party/node/deps/npm/node_modules/es6-promise/lib/es6-promise/ |
| D | then.js | 3 subscribe,
28 subscribe(parent, child, onFulfillment, onRejection);
|
| D | -internal.js | 68 subscribe(thenable, undefined, value => resolve(promise, value),
133 function subscribe(parent, child, onFulfillment, onRejection) { function
234 subscribe,
|
| /third_party/libwebsockets/lib/secure-streams/protocols/ |
| D | ss-mqtt.c | 65 if (!h->policy->u.mqtt.subscribe || wsi->mqtt->done_subscribe) in secstream_mqtt_subscribe()
75 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe, in secstream_mqtt_subscribe()
76 strlen(h->policy->u.mqtt.subscribe), &used_in, in secstream_mqtt_subscribe()
97 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe, in secstream_mqtt_subscribe()
98 strlen(h->policy->u.mqtt.subscribe), &used_in, in secstream_mqtt_subscribe()
288 if (!h->policy->u.mqtt.subscribe || in secstream_mqtt()
289 !h->policy->u.mqtt.subscribe[0]) { in secstream_mqtt()
306 } else if (h->policy->u.mqtt.subscribe && in secstream_mqtt()
393 if (!wsi->mqtt->done_subscribe && h->policy->u.mqtt.subscribe) in secstream_mqtt()
499 h->policy->u.mqtt.subscribe, in secstream_connect_munge_mqtt()
|
| /third_party/ffmpeg/libavformat/ |
| D | librtmp.c | 44 char *subscribe; member
143 if (ctx->subscribe) in rtmp_open()
144 len += strlen(ctx->subscribe) + sizeof(" subscribe="); in rtmp_open()
206 if (ctx->subscribe) { in rtmp_open()
208 av_strlcat(filename, ctx->subscribe, len); in rtmp_open()
332 …ame of live stream to subscribe to. Defaults to rtmp_playpath.", OFFSET(subscribe), AV_OPT_TYPE_ST…
|
| /third_party/curl/docs/ |
| D | MQTT.md | 8 Example subscribe:
16 ## What does curl deliver as a response to a subscribe
|
| /third_party/node/benchmark/diagnostics_channel/ |
| D | http.js | 89 start.subscribe(onStart);
90 finish.subscribe(onFinish);
|