| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 33 printf("[thread %s] Start task\n", get_pid().c_str());
43 [](long v){printf("[thread %s][1] OnNext: %ld\n", get_pid().c_str(), v);}, in __anond4f2187e0602()
44 [](){printf("[thread %s][1] OnCompleted\n", get_pid().c_str());}); in __anond4f2187e0602()
50 [](long v){printf("[thread %s][2] OnNext: %ld\n", get_pid().c_str(), v);}, in __anond4f2187e0902()
51 [](){printf("[thread %s][2] OnCompleted\n", get_pid().c_str());}); in __anond4f2187e0902()
61 printf("[thread %s] Finish task\n", get_pid().c_str());
90 printf("[thread %s] Start task\n", get_pid().c_str());
100 [](long v){printf("[thread %s][1] OnNext: %ld\n", get_pid().c_str(), v);}, in __anond4f2187e1202()
101 [](){printf("[thread %s][1] OnCompleted\n", get_pid().c_str());}); in __anond4f2187e1202()
107 [](long v){printf("[thread %s][2] OnNext: %ld\n", get_pid().c_str(), v);}, in __anond4f2187e1502()
[all …]
|
| D | merge_delay_error.cpp | 42 printf("[thread %s] Start task\n", get_pid().c_str());
44 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon87c160b80b02()
49 ss << "[thread " << get_pid().c_str() << "] Timer2 failed\n"; in __anon87c160b80c02()
52 ss << "(Error from thread: " << get_pid().c_str() << ")\n"; in __anon87c160b80c02()
56 printf("[thread %s] Timer3 fired\n", get_pid().c_str()); in __anon87c160b80d02()
63 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon87c160b80e02()
64 …[](std::exception_ptr eptr) { printf("[thread %s] OnError %s\n", get_pid().c_str(), rxu::what(eptr… in __anon87c160b80f02()
65 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon87c160b81002()
66 printf("[thread %s] Finish task\n", get_pid().c_str());
72 printf("[thread %s] Start task\n", get_pid().c_str());
[all …]
|
| D | amb.cpp | 37 printf("[thread %s] Start task\n", get_pid().c_str());
39 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon880b2ba10b02()
43 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anon880b2ba10c02()
47 printf("[thread %s] Timer3 fired\n", get_pid().c_str()); in __anon880b2ba10d02()
54 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon880b2ba10e02()
55 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon880b2ba10f02()
56 printf("[thread %s] Finish task\n", get_pid().c_str());
62 printf("[thread %s] Start task\n", get_pid().c_str());
64 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon880b2ba11002()
68 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anon880b2ba11102()
[all …]
|
| D | merge.cpp | 37 printf("[thread %s] Start task\n", get_pid().c_str());
39 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon1fe4ec610b02()
43 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anon1fe4ec610c02()
47 printf("[thread %s] Timer3 fired\n", get_pid().c_str()); in __anon1fe4ec610d02()
54 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon1fe4ec610e02()
55 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon1fe4ec610f02()
56 printf("[thread %s] Finish task\n", get_pid().c_str());
62 printf("[thread %s] Start task\n", get_pid().c_str());
64 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon1fe4ec611002()
68 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anon1fe4ec611102()
[all …]
|
| D | take_until.cpp | 33 printf("[thread %s] Start task\n", get_pid().c_str());
35 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v); in __anon9a6b76e10502()
39 printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v); in __anon9a6b76e10602()
46 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon9a6b76e10702()
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon9a6b76e10802()
48 printf("[thread %s] Finish task\n", get_pid().c_str());
54 printf("[thread %s] Start task\n", get_pid().c_str());
56 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v); in __anon9a6b76e10902()
64 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon9a6b76e10a02()
65 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon9a6b76e10b02()
[all …]
|
| D | skip_until.cpp | 22 printf("[thread %s] Start task\n", get_pid().c_str());
24 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v); in __anond1f6ab530302()
28 printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v); in __anond1f6ab530402()
35 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);}, in __anond1f6ab530502()
36 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anond1f6ab530602()
37 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | observe_on.cpp | 10 printf("[thread %s] Start task\n", get_pid().c_str());
13 printf("[thread %s] Emit value %d\n", get_pid().c_str(), v); in __anon79b52ec30102()
20 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon79b52ec30202()
21 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon79b52ec30302()
22 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | subscribe_on.cpp | 10 printf("[thread %s] Start task\n", get_pid().c_str());
13 printf("[thread %s] Emit value %d\n", get_pid().c_str(), v); in __anonc7bcc86f0102()
20 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anonc7bcc86f0202()
21 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonc7bcc86f0302()
22 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | flat_map.cpp | 29 printf("[thread %s] Start task\n", get_pid().c_str());
33 printf("[thread %s] Call CollectionSelector(v = %d)\n", get_pid().c_str(), v); in __anon9ebf45b50502()
39 …printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %d)\n", get_pid().c_str(), v_main, v_… in __anon9ebf45b50602()
46 …[](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0… in __anon9ebf45b50702()
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon9ebf45b50802()
48 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | concat_map.cpp | 29 printf("[thread %s] Start task\n", get_pid().c_str());
33 printf("[thread %s] Call CollectionSelector(v = %d)\n", get_pid().c_str(), v); in __anon18ff81a60502()
39 …printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %ld)\n", get_pid().c_str(), v_main, v… in __anon18ff81a60602()
46 …[](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0… in __anon18ff81a60702()
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon18ff81a60802()
48 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | from.cpp | 20 printf("[thread %s] Start task\n", get_pid().c_str());
22 printf("[thread %s] Emit value: %d\n", get_pid().c_str(), v); in __anonca46c8e50302()
28 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anonca46c8e50402()
29 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonca46c8e50502()
30 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | range.cpp | 20 printf("[thread %s] Start task\n", get_pid().c_str());
23 map([](int v) { return std::make_tuple(get_pid(), v);}); in __anon8162dade0302()
31 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon8162dade0502()
32 printf("[thread %s] Finish task\n", get_pid().c_str());
38 printf("[thread %s] Start task\n", get_pid().c_str());
42 map([](int v) { return std::make_tuple(get_pid(), v);}); in __anon8162dade0602()
50 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon8162dade0802()
51 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | with_latest_from.cpp | 24 printf("[thread %s] Start task\n", get_pid().c_str());
27 printf("[thread %s] Source1 OnNext: %d\n", get_pid().c_str(), v); in __anon563eb62c0302()
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v); in __anon563eb62c0402()
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v); in __anon563eb62c0502()
43 …[](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std:… in __anon563eb62c0602()
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon563eb62c0702()
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | combine_latest.cpp | 24 printf("[thread %s] Start task\n", get_pid().c_str());
27 printf("[thread %s] Source1 OnNext: %d\n", get_pid().c_str(), v); in __anon6802417a0302()
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v); in __anon6802417a0402()
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v); in __anon6802417a0502()
43 …[](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std:… in __anon6802417a0602()
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon6802417a0702()
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | zip.cpp | 24 printf("[thread %s] Start task\n", get_pid().c_str());
27 printf("[thread %s] Source1 OnNext: %d\n", get_pid().c_str(), v); in __anon0423cf040302()
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v); in __anon0423cf040402()
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v); in __anon0423cf040502()
43 …[](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std:… in __anon0423cf040602()
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon0423cf040702()
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | buffer.cpp | 42 printf("[thread %s] Start task\n", get_pid().c_str());
47 printf("[thread %s] Interval OnNext: %ld\n", get_pid().c_str(), v); in __anondc76502b0702()
56 printf("[thread %s] OnNext:", get_pid().c_str()); in __anondc76502b0802()
62 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anondc76502b0a02()
63 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | main.hpp | 3 std::string get_pid();
|
| D | main.cpp | 10 std::string get_pid() { in get_pid() function
|
| /external/python/cpython3/Lib/asyncio/ |
| D | transports.py | 183 def get_pid(self): member in SubprocessTransport
|
| D | subprocess.py | 114 self.pid = transport.get_pid()
|
| D | base_subprocess.py | 129 def get_pid(self): member in BaseSubprocessTransport
|
| D | unix_events.py | 192 watcher.add_child_handler(transp.get_pid(),
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_transports.py | 58 self.assertRaises(NotImplementedError, transport.get_pid)
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-llapi-index.rst | 382 * - :meth:`transport.get_pid() <SubprocessTransport.get_pid>`
|
| D | asyncio-protocol.rst | 374 .. method:: SubprocessTransport.get_pid()
|