| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| main.hpp | 3 std::string get_pid();
|
| 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);
20 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
21 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
22 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
20 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
21 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
22 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
28 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
29 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
30 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
39 printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v);
46 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
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);
64 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
65 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());})
[all...] |
| amb.cpp | 37 printf("[thread %s] Start task\n", get_pid().c_str());
39 printf("[thread %s] Timer1 fired\n", get_pid().c_str());
43 printf("[thread %s] Timer2 fired\n", get_pid().c_str());
47 printf("[thread %s] Timer3 fired\n", get_pid().c_str());
54 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
55 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
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());
68 printf("[thread %s] Timer2 fired\n", get_pid().c_str())
[all...] |
| merge.cpp | 37 printf("[thread %s] Start task\n", get_pid().c_str());
39 printf("[thread %s] Timer1 fired\n", get_pid().c_str());
43 printf("[thread %s] Timer2 fired\n", get_pid().c_str());
47 printf("[thread %s] Timer3 fired\n", get_pid().c_str());
54 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
55 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
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());
68 printf("[thread %s] Timer2 fired\n", get_pid().c_str())
[all...] |
| 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());
49 ss << "[thread " << get_pid().c_str() << "] Timer2 failed\n";
52 ss << "(Error from thread: " << get_pid().c_str() << ")\n";
56 printf("[thread %s] Timer3 fired\n", get_pid().c_str());
63 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
64 [](std::exception_ptr eptr) { printf("[thread %s] OnError %s\n", get_pid().c_str(), rxu::what(eptr).c_str()); },
65 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
66 printf("[thread %s] Finish task\n", get_pid().c_str());
72 printf("[thread %s] Start task\n", get_pid().c_str())
[all...] |
| main.cpp | 10 std::string get_pid() { function
|
| 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);
39 printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %ld)\n", get_pid().c_str(), v_main, v_sub);
46 [](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v));},
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
48 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
39 printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %d)\n", get_pid().c_str(), v_main, v_sub);
46 [](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v));},
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
48 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);},
44 [](){printf("[thread %s][1] OnCompleted\n", get_pid().c_str());});
50 [](long v){printf("[thread %s][2] OnNext: %ld\n", get_pid().c_str(), v);},
51 [](){printf("[thread %s][2] OnCompleted\n", get_pid().c_str());});
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);},
101 [](){printf("[thread %s][1] OnCompleted\n", get_pid().c_str());});
107 [](long v){printf("[thread %s][2] OnNext: %ld\n", get_pid().c_str(), v);}
[all...] |
| 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);
28 printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v);
35 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
36 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
37 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v);
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v);
43 [](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v), std::get<2>(v));},
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v);
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v);
43 [](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v), std::get<2>(v));},
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v);
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v);
43 [](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v), std::get<2>(v));},
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| range.cpp | 20 printf("[thread %s] Start task\n", get_pid().c_str());
23 map([](int v) { return std::make_tuple(get_pid(), v);});
31 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
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);});
50 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
51 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| 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);
56 printf("[thread %s] OnNext:", get_pid().c_str());
62 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
63 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| /external/python/cpython3/Lib/asyncio/ |
| transports.py | 183 def get_pid(self): member in class:SubprocessTransport
|
| subprocess.py | 114 self.pid = transport.get_pid()
|
| base_subprocess.py | 129 def get_pid(self): member in class:BaseSubprocessTransport
|
| unix_events.py | 192 watcher.add_child_handler(transp.get_pid(),
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_transports.py | 58 self.assertRaises(NotImplementedError, transport.get_pid)
|
