| /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 __anonf17a94ca0502()
30 values.subscribe( in __anonf17a94ca0502()
36 values.as_blocking().subscribe();
47 values.subscribe(
52 values.subscribe(
60 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anonf17a94ca0c02()
61 values.subscribe( in __anonf17a94ca0c02()
67 values.as_blocking().subscribe();
[all …]
|
| D | replay.cpp | 15 values.subscribe(
23 rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){ in __anon0d788ac00302()
24 values.as_blocking().subscribe( in __anon0d788ac00302()
42 values.subscribe( in __anon0d788ac00602()
49 values.subscribe( in __anon0d788ac00902()
60 values.as_blocking().subscribe();
72 values.subscribe(
80 rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){ in __anon0d788ac00f02()
81 values.as_blocking().subscribe( in __anon0d788ac00f02()
99 values.subscribe( in __anon0d788ac01202()
[all …]
|
| D | window.cpp | 11 subscribe(
15 v.subscribe( in __anond3cd9c6b0102()
27 subscribe(
31 v.subscribe( in __anond3cd9c6b0402()
48 subscribe(
52 v.subscribe( in __anond3cd9c6b0702()
68 subscribe(
72 v.subscribe( in __anond3cd9c6b0a02()
88 subscribe(
92 v.subscribe( in __anond3cd9c6b0d02()
[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 __anon43e5c2a80502()
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 __anon43e5c2a80e02()
[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 __anon537874500b02()
370 on.subscribe(200, 200 + 10 * ++i) in __anon537874500e02()
[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 __anon0aae269e0b02()
371 on.subscribe(200, 200 + 10 * ++i) in __anon0aae269e0e02()
[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 __anon1940ffec1302()
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 __anon0ead19a20202()
103 on.subscribe(300, 400),
104 on.subscribe(500, 550),
105 on.subscribe(650, 800)
153 ys.subscribe(res); in __anon0ead19a20b02()
205 on.subscribe(300, 400),
206 on.subscribe(500, 600)
262 w.schedule_absolute(200, [&ys, &res1](const rxsc::schedulable&){ys.subscribe(res1);}); in __anon0ead19a21402()
266 w.schedule_absolute(400, [&ys, &res2](const rxsc::schedulable&){ys.subscribe(res2);}); in __anon0ead19a21502()
270 w.schedule_absolute(600, [&ys, &res3](const rxsc::schedulable&){ys.subscribe(res3);}); in __anon0ead19a21602()
[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)
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowableExceptionHandlingTest.kt | 31 }.subscribe({ in <lambda>()
44 }.subscribe({ in <lambda>()
59 .subscribe({ in <lambda>()
74 .subscribe({ in <lambda>()
87 }.subscribe({ in <lambda>()
99 }.subscribe({ in <lambda>()
113 .subscribe({ in <lambda>()
127 .subscribe({ in <lambda>()
|
| D | ObservableExceptionHandlingTest.kt | 31 }.subscribe({ in <lambda>()
44 }.subscribe({ in <lambda>()
59 .subscribe({ in <lambda>()
74 .subscribe({ in <lambda>()
87 }.subscribe({ in <lambda>()
99 }.subscribe({ in <lambda>()
113 .subscribe({ in <lambda>()
127 .subscribe({ in <lambda>()
|
| D | CompletableTest.kt | 22 completable.subscribe { in <lambda>()
38 completable.subscribe({ in <lambda>()
60 val sub = completable.subscribe({ in <lambda>()
138 completable.subscribe(object : CompletableObserver { in <lambda>()
156 }.subscribe({ throw LinkageError() }) in <lambda>()
164 }.subscribe({ expectUnreached() }, { expect(1); assertTrue(it is LinkageError) }) in <lambda>()
|