| /external/tensorflow/tensorflow/python/framework/ |
| D | subscribe_test.py | 27 from tensorflow.python.framework import subscribe
44 all(subscribe._is_subscribed_identity(x) for x in container))
63 c = subscribe.subscribe(c,
91 subscribed = subscribe.subscribe(
97 subscribed = subscribe.subscribe(
103 subscribed = subscribe.subscribe({
115 subscribed = subscribe.subscribe(
122 subscribe.subscribe(c.name,
139 a = subscribe.subscribe(a,
147 b = subscribe.subscribe(b,
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | publish.cpp | 16 values.subscribe(
21 values.subscribe(
29 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anond2b5055f0502()
30 values.subscribe( in __anond2b5055f0502()
36 values.as_blocking().subscribe();
47 values.subscribe(
52 values.subscribe(
60 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anond2b5055f0c02()
61 values.subscribe( in __anond2b5055f0c02()
67 values.as_blocking().subscribe();
[all …]
|
| D | replay.cpp | 15 values.subscribe(
23 rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){ in __anon982cbcb50302()
24 values.as_blocking().subscribe( in __anon982cbcb50302()
42 values.subscribe( in __anon982cbcb50602()
49 values.subscribe( in __anon982cbcb50902()
60 values.as_blocking().subscribe();
72 values.subscribe(
80 rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){ in __anon982cbcb50f02()
81 values.as_blocking().subscribe( in __anon982cbcb50f02()
99 values.subscribe( in __anon982cbcb51202()
[all …]
|
| D | window.cpp | 11 subscribe(
15 v.subscribe( in __anon5e81ce600102()
27 subscribe(
31 v.subscribe( in __anon5e81ce600402()
48 subscribe(
52 v.subscribe( in __anon5e81ce600702()
68 subscribe(
72 v.subscribe( in __anon5e81ce600a02()
88 subscribe(
92 v.subscribe( in __anon5e81ce600d02()
[all …]
|
| D | math.cpp | 10 subscribe(
21 subscribe(
38 subscribe(
49 subscribe(
66 subscribe(
79 subscribe(
96 subscribe(
107 subscribe(
126 subscribe(
142 subscribe(
[all …]
|
| D | subscribe.cpp | 12 values.subscribe(subscriber);
23 values1.subscribe(subscriber.get_observer());
24 values2.subscribe(subscriber.get_observer());
31 values.subscribe(
40 values.subscribe(
54 values.subscribe(
64 values.subscribe(
79 values.subscribe(
96 auto subscription = values.subscribe(
|
| D | buffer.cpp | 10 subscribe(
26 subscribe(
54 subscribe(
75 subscribe(
95 subscribe(
114 subscribe(
133 subscribe(
151 subscribe(
172 subscribe(
192 subscribe(
|
| D | range.cpp | 10 subscribe(
26 subscribe(
45 subscribe(
71 subscribe(rxcpp::util::apply_to(
93 subscribe(rxcpp::util::apply_to(
120 subscribe(rxcpp::util::apply_to(
146 subscribe(rxcpp::util::apply_to(
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | amb.cpp | 49 on.subscribe(200, 400)
57 on.subscribe(300, 1000)
65 on.subscribe(300, 1000)
73 on.subscribe(300, 1000)
125 on.subscribe(200, 350)
133 on.subscribe(300, 400)
141 on.subscribe(300, 400)
209 on.subscribe(200, 300)
217 on.subscribe(300, 610)
225 on.subscribe(300, 310)
[all …]
|
| D | flat_map.cpp | 79 .subscribe(
300 i_on.subscribe(200, 700)
308 s_on.subscribe(300, 550),
309 s_on.subscribe(400, 650),
310 s_on.subscribe(500, 750),
311 s_on.subscribe(600, 850)
384 i_on.subscribe(200, 700)
392 s_on.subscribe(300, 550),
393 s_on.subscribe(400, 650),
394 s_on.subscribe(500, 750),
[all …]
|
| D | zip.cpp | 42 on.subscribe(200, 1000)
50 on.subscribe(200, 1000)
102 on.subscribe(200, 1000) in __anond350a77d0502()
151 on.subscribe(200, 1000)
159 on.subscribe(200, 210)
207 on.subscribe(200, 210)
215 on.subscribe(200, 1000)
266 on.subscribe(200, 210)
274 on.subscribe(200, 210)
330 on.subscribe(200, 200 + 10 * ++i) in __anond350a77d0e02()
[all …]
|
| D | combine_latest.cpp | 57 on.subscribe(200, 230)
65 on.subscribe(200, 250)
122 on.subscribe(200, 230)
130 on.subscribe(200, 250)
187 on.subscribe(200, 230)
195 on.subscribe(200, 230)
254 on.subscribe(200, 245)
262 on.subscribe(200, 245)
314 on.subscribe(200, 1000) in __anon5d7f3c530b02()
371 on.subscribe(200, 200 + 10 * ++i) in __anon5d7f3c530e02()
[all …]
|
| D | with_latest_from.cpp | 56 on.subscribe(200, 230)
64 on.subscribe(200, 250)
121 on.subscribe(200, 230)
129 on.subscribe(200, 250)
186 on.subscribe(200, 230)
194 on.subscribe(200, 230)
253 on.subscribe(200, 245)
261 on.subscribe(200, 245)
313 on.subscribe(200, 1000) in __anon9ee5cb450b02()
370 on.subscribe(200, 200 + 10 * ++i) in __anon9ee5cb450e02()
[all …]
|
| D | amb_variadic.cpp | 41 on.subscribe(200, 1000)
49 on.subscribe(200, 1000)
57 on.subscribe(200, 1000)
102 on.subscribe(200, 400)
110 on.subscribe(200, 400)
155 on.subscribe(200, 400)
163 on.subscribe(200, 400)
223 on.subscribe(200, 510)
231 on.subscribe(200, 210)
239 on.subscribe(200, 210)
[all …]
|
| D | skip_until.cpp | 48 on.subscribe(200, 250)
56 on.subscribe(200, 225)
108 on.subscribe(200, 225)
116 on.subscribe(200, 225)
166 on.subscribe(200, 220)
174 on.subscribe(200, 220)
222 on.subscribe(200, 250)
230 on.subscribe(200, 225)
274 on.subscribe(200, 1000)
282 on.subscribe(200, 225)
[all …]
|
| D | take_until.cpp | 49 on.subscribe(200, 225)
57 on.subscribe(200, 225)
111 on.subscribe(200, 225)
119 on.subscribe(200, 225)
174 on.subscribe(200, 225)
182 on.subscribe(200, 225)
237 on.subscribe(200, 250)
245 on.subscribe(200, 225)
299 on.subscribe(200, 250)
307 on.subscribe(200, 250)
[all …]
|
| D | publish.cpp | 14 published.subscribe(
25 published.subscribe(
34 published.subscribe(
49 published.subscribe(
75 with_ref_count.subscribe(
114 with_ref_count.subscribe(
178 ys.subscribe(res); in __anon7a8c47411302()
241 on.subscribe(300, 400),
242 on.subscribe(500, 550),
243 on.subscribe(650, 800)
[all …]
|
| D | repeat.cpp | 47 on.subscribe(200, 450),
48 on.subscribe(450, 700),
49 on.subscribe(700, 950),
50 on.subscribe(950, 1000)
135 on.subscribe(200, 1000)
183 on.subscribe(200, 450)
235 on.subscribe(200, 220),
236 on.subscribe(220, 240),
237 on.subscribe(240, 260)
285 on.subscribe(200, 220),
[all …]
|
| D | replay.cpp | 40 ys.subscribe(res); in __anondb524a570202()
103 on.subscribe(300, 400),
104 on.subscribe(500, 550),
105 on.subscribe(650, 800)
153 ys.subscribe(res); in __anondb524a570b02()
205 on.subscribe(300, 400),
206 on.subscribe(500, 600)
262 w.schedule_absolute(200, [&ys, &res1](const rxsc::schedulable&){ys.subscribe(res1);}); in __anondb524a571402()
266 w.schedule_absolute(400, [&ys, &res2](const rxsc::schedulable&){ys.subscribe(res2);}); in __anondb524a571502()
270 w.schedule_absolute(600, [&ys, &res3](const rxsc::schedulable&){ys.subscribe(res3);}); in __anondb524a571602()
[all …]
|
| D | switch_on_next.cpp | 73 o_on.subscribe(200, 600)
81 on.subscribe(300, 400)
89 on.subscribe(400, 450)
97 on.subscribe(500, 650)
172 o_on.subscribe(200, 450)
180 on.subscribe(300, 400)
188 on.subscribe(400, 450)
260 o_on.subscribe(200, 500)
268 on.subscribe(300, 400)
276 on.subscribe(400, 450)
[all …]
|
| D | concat_map.cpp | 44 .subscribe(
256 i_on.subscribe(200, 700)
264 s_on.subscribe(300, 550),
265 s_on.subscribe(550, 800)
328 i_on.subscribe(200, 700)
336 s_on.subscribe(300, 550),
337 s_on.subscribe(550, 800)
378 i_on.subscribe(200, 700)
386 s_on.subscribe(300, 550),
387 s_on.subscribe(550, 800)
[all …]
|
| D | merge_delay_error.cpp | 85 on.subscribe(200, 600)
93 on.subscribe(300, 530)
101 on.subscribe(400, 450)
109 on.subscribe(500, 650)
187 on.subscribe(200, 440)
195 on.subscribe(200, 240)
203 on.subscribe(200, 350)
281 on.subscribe(200, 420)
289 on.subscribe(200, 240)
297 on.subscribe(200, 350)
|
| D | sequence_equal.cpp | 41 on.subscribe(200, 1000)
87 on.subscribe(200, 610)
128 on.subscribe(200, 1000)
183 on.subscribe(200, 610)
237 on.subscribe(200, 610)
291 on.subscribe(200, 610)
346 on.subscribe(200, 330)
401 on.subscribe(200, 330)
449 on.subscribe(200, 250)
497 on.subscribe(200, 310)
[all …]
|
| D | reduce.cpp | 50 on.subscribe(200, 260)
105 on.subscribe(200, 260)
148 on.subscribe(200, 250)
191 on.subscribe(200, 250)
234 on.subscribe(200, 250)
279 on.subscribe(200, 250)
320 on.subscribe(200, 250)
363 on.subscribe(200, 250)
407 on.subscribe(200, 250)
448 on.subscribe(200, 250)
|
| /external/ltp/utils/sctp/func_tests/ |
| D | test_sctp_sendrecvmsg.c | 83 struct sctp_event_subscribe subscribe; in main() local
133 memset(&subscribe, 0, sizeof(subscribe)); in main()
134 subscribe.sctp_data_io_event = 1; in main()
135 subscribe.sctp_association_event = 1; in main()
136 subscribe.sctp_send_failure_event = 1; in main()
137 test_setsockopt(sk1, SCTP_EVENTS, &subscribe, sizeof(subscribe)); in main()
138 test_setsockopt(sk2, SCTP_EVENTS, &subscribe, sizeof(subscribe)); in main()
|