Home
last modified time | relevance | path

Searched refs:subscribe (Results 1 – 25 of 178) sorted by relevance

12345678

/third_party/typescript/tests/baselines/reference/
DgenericCallbacksAndClassHierarchy.symbols9 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))
DgenericCallbacksAndClassHierarchy.types6 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
DsymbolProperty61.types26 subscribe(next: (val: T) => void) {
27 >subscribe : (next: (val: T) => void) => void
51 [Symbol.obs]: () => { subscribe(next: (val: T) => void): void }
52 >[Symbol.obs] : () => { subscribe(next: (val: T) => void): void; }
56 >subscribe : (next: (val: T) => void) => void
62 >from : <T>(obs: InteropObservable<T>) => { subscribe(next: (val: T) => void): void; }
66 >obs[Symbol.obs]() : { subscribe(next: (val: T) => void): void; }
67 >obs[Symbol.obs] : () => { subscribe(next: (val: T) => void): void; }
75 >from(new MyObservable(42)) : { subscribe(next: (val: number) => void): void; }
76 >from : <T>(obs: InteropObservable<T>) => { subscribe(next: (val: T) => void): void; }
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) { });
DsymbolProperty61.js13 subscribe(next: (val: T) => void) { method in MyObservable
23 [Symbol.obs]: () => { subscribe(next: (val: T) => void): void }
39 subscribe(next) { method in MyObservable
62 subscribe(next: (val: T) => void): void;
DobservableInferenceCanBeMade.symbols34 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))
DsymbolProperty61.symbols30 subscribe(next: (val: T) => void) {
31 >subscribe : Symbol(MyObservable.subscribe, Decl(symbolProperty61.ts, 9, 35))
56 [Symbol.obs]: () => { subscribe(next: (val: T) => void): void }
61 >subscribe : Symbol(subscribe, Decl(symbolProperty61.ts, 21, 25))
DobservableInferenceCanBeMade.types16 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, …
/third_party/node/deps/undici/src/docs/api/
DDiagnosticsChannel.md17 diagnosticsChannel.channel('undici:request:create').subscribe(({ request }) => {
36 diagnosticsChannel.channel('undici:request:bodySent').subscribe(({ request }) => {
48 diagnosticsChannel.channel('undici:request:headers').subscribe(({ request, response }) => {
64 diagnosticsChannel.channel('undici:request:trailers').subscribe(({ request, trailers }) => {
79 diagnosticsChannel.channel('undici:request:error').subscribe(({ request, error }) => {
93 diagnosticsChannel.channel('undici:client:sendHeaders').subscribe(({ request, headers, socket }) =>…
107 diagnosticsChannel.channel('undici:client:beforeConnect').subscribe(({ connectParams, connector }) …
120 diagnosticsChannel.channel('undici:client:connected').subscribe(({ socket, connectParams, connector…
133 diagnosticsChannel.channel('undici:client:connectError').subscribe(({ error, socket, connectParams,…
147 diagnosticsChannel.channel('undici:websocket:open').subscribe(({ address, protocol, extensions }) =…
[all …]
/third_party/ltp/utils/sctp/func_tests/
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()
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()
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/
Dtest-diagnostics-channel-pub-sub.js26 dc.subscribe(name, subscriber);
43 dc.subscribe(name, null);
49 channel.subscribe(subscriber);
51 channel.subscribe(subscriber);
Dtest-diagnostics-channel-http.js13 dc.subscribe('http.client.request.start', common.mustCall(({ request }) => {
17 dc.subscribe('http.client.response.finish', common.mustCall(({
25 dc.subscribe('http.server.request.start', common.mustCall(({
37 dc.subscribe('http.server.response.finish', common.mustCall(({
Dtest-diagnostics-channel-memory-leak.js9 const { subscribe, unsubscribe } = require('diagnostics_channel');
16 subscribe(String(i), noop);
Dtest-diagnostics-channel-safe-subscriber-errors.js19 channel.subscribe(common.mustCall((message, name) => {
24 channel.subscribe(common.mustCall());
Dtest-diagnostics-channel-net.js9 dc.subscribe('net.client.socket', common.mustCall(({ socket }) => {
13 dc.subscribe('net.server.socket', common.mustCall(({ socket }) => {
Dtest-diagnostics-channel-object-channel-pub-sub.js28 channel.subscribe(subscriber);
45 channel.subscribe(null);
/third_party/node/lib/
Ddiagnostics_channel.js96 subscribe(subscription) { method in ActiveChannel
181 subscribe(subscription) { method in Channel
183 this.subscribe(subscription);
223 function subscribe(name, subscription) { function
224 return channel(name).subscribe(subscription);
281 subscribe(handlers) { method in TracingChannel
285 this[name]?.subscribe(handlers[name]);
409 subscribe, property
/third_party/typescript/tests/cases/compiler/
DgenericCallbacksAndClassHierarchy.ts3 subscribe(callback: (newValue: T) => void ): any; method
19 v.subscribe(f);
20 v.subscribe((newValue: A<T>) => { });
DobservableInferenceCanBeMade.ts11 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/ltp/utils/sctp/testlib/
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/libsnd/docs/
Dlists.md14 [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/doc/api/
Ddiagnostics_channel.md61 diagnostics_channel.subscribe('my-channel', onMessage);
86 diagnostics_channel.subscribe('my-channel', onMessage);
160 #### `diagnostics_channel.subscribe(name, onMessage)`
172 Register a message handler to subscribe to this channel. This message handler
179 diagnostics_channel.subscribe('my-channel', (message, name) => {
187 diagnostics_channel.subscribe('my-channel', (message, name) => {
204 [`diagnostics_channel.subscribe(name, onMessage)`][].
213 diagnostics_channel.subscribe('my-channel', onMessage);
225 diagnostics_channel.subscribe('my-channel', onMessage);
365 #### `channel.subscribe(onMessage)`
[all …]
/third_party/typescript/tests/cases/conformance/es6/Symbols/
DsymbolProperty61.ts15 subscribe(next: (val: T) => void) { method in MyObservable
25 [Symbol.obs]: () => { subscribe(next: (val: T) => void): void }

12345678