RxCpp
The Reactive Extensions for Native (RxCpp) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in both C and C++.
|
For each item from this observable use the CollectionSelector to produce an observable and subscribe to that observable. For each item from all of the produced observables use the ResultSelector to produce a value to emit from the new observable that is returned. More...
#include "../rx-includes.hpp"
Go to the source code of this file.
Classes | |
struct | rxcpp::member_overload< concat_map_tag > |
Namespaces | |
rxcpp | |
rxcpp::operators | |
Macros | |
#define | RXCPP_OPERATORS_RX_CONCATMAP_HPP |
Functions | |
template<class... AN> | |
auto | rxcpp::operators::concat_map (AN &&... an) -> operator_factory< concat_map_tag, AN... > |
For each item from this observable use the CollectionSelector to produce an observable and subscribe to that observable. For each item from all of the produced observables use the ResultSelector to produce a value to emit from the new observable that is returned. More... | |
template<class... AN> | |
auto | rxcpp::operators::concat_transform (AN &&... an) -> operator_factory< concat_map_tag, AN... > |
For each item from this observable use the CollectionSelector to produce an observable and subscribe to that observable. For each item from all of the produced observables use the ResultSelector to produce a value to emit from the new observable that is returned. More... | |
For each item from this observable use the CollectionSelector to produce an observable and subscribe to that observable. For each item from all of the produced observables use the ResultSelector to produce a value to emit from the new observable that is returned.
CollectionSelector | the type of the observable producing function. CollectionSelector must be a function with the signature: observable(concat_map::source_value_type) |
ResultSelector | the type of the aggregation function (optional). ResultSelector must be a function with the signature: concat_map::value_type(concat_map::source_value_type, concat_map::collection_value_type) |
Coordination | the type of the scheduler (optional). |
s | a function that returns an observable for each item emitted by the source observable. |
rs | a function that combines one item emitted by each of the source and collection observables and returns an item to be emitted by the resulting observable (optional). |
cn | the scheduler to synchronize sources from different contexts. (optional). |
Observables, produced by the CollectionSelector, are concatenated. There is another operator rxcpp::observable<T,SourceType>::flat_map that works similar but merges the observables.
#define RXCPP_OPERATORS_RX_CONCATMAP_HPP |