All values are queued and delivered using the scheduler from the supplied coordination.
More...
All values are queued and delivered using the scheduler from the supplied coordination.
- Template Parameters
-
Coordination | the type of the scheduler. |
- Parameters
-
cn | the scheduler to notify observers on. |
- Returns
- The source observable modified so that its observers are notified on the specified scheduler.
- Sample Code\n
printf("[thread %s] Start task\n", get_pid().c_str());
printf("[thread %s] Emit value %d\n", get_pid().c_str(), v);
return v;
});
values.
[](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
[](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
printf("[thread %s] Finish task\n", get_pid().c_str());
[thread 3069620240] Start task
[thread 3069620240] Emit value 1
[thread 3069620240] Emit value 2
[thread 3069620240] Emit value 3
[thread 3024090176] OnNext: 1
[thread 3024090176] OnNext: 2
[thread 3024090176] OnNext: 3
[thread 3024090176] OnCompleted
[thread 3069620240] Finish task
Invoking rxcpp::observable::subscribe_on operator, instead of observe_on, gives following results: [thread 3069620240] Start task
[thread 2977944640] Emit value 1
[thread 2977944640] OnNext: 1
[thread 2977944640] Emit value 2
[thread 2977944640] OnNext: 2
[thread 2977944640] Emit value 3
[thread 2977944640] OnNext: 3
[thread 2977944640] OnCompleted
[thread 3069620240] Finish task