caf::flow::observable_def< Materializer, Steps > Member List

This is the complete list of members for caf::flow::observable_def< Materializer, Steps >, including all inherited members.

as_observable() &&	caf::flow::observable_def< Materializer, Steps >
buffer(size_t count) &&	caf::flow::observable_def< Materializer, Steps >
buffer(size_t count, timespan period) (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
compose(Fn &&fn) &&	caf::flow::observable_def< Materializer, Steps >
concat(Inputs &&... xs) &&	caf::flow::observable_def< Materializer, Steps >
concat_map(F f) &&	caf::flow::observable_def< Materializer, Steps >
distinct() && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
do_finally(F f) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
do_on_complete(F f) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
do_on_error(F f) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
do_on_next(F f) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
element_at(size_t n) &&	caf::flow::observable_def< Materializer, Steps >
filter(Predicate predicate) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
first() &&	caf::flow::observable_def< Materializer, Steps >
flat_map(F f) &&	caf::flow::observable_def< Materializer, Steps >
for_each(OnNext on_next) &&	caf::flow::observable_def< Materializer, Steps >
for_each(OnNext on_next, OnError on_error) &&	caf::flow::observable_def< Materializer, Steps >
head_and_tail() &&	caf::flow::observable_def< Materializer, Steps >
ignore_elements() &&	caf::flow::observable_def< Materializer, Steps >
last() &&	caf::flow::observable_def< Materializer, Steps >
map(F f) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
merge(Inputs &&... xs) &&	caf::flow::observable_def< Materializer, Steps >
observable_def()=delete (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
observable_def(const observable_def &)=delete (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
observable_def(observable_def &&)=default (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
observable_def(Materializer &&materializer) (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >	explicit
observable_def(Materializer &&materializer, std::tuple< Steps... > &&steps) (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
observe_on(coordinator *other) &&	caf::flow::observable_def< Materializer, Steps >
observe_on(coordinator *other, size_t buffer_size, size_t min_request_size) &&	caf::flow::observable_def< Materializer, Steps >
on_backpressure_buffer(size_t buffer_size, backpressure_overflow_strategy strategy=backpressure_overflow_strategy::fail)	caf::flow::observable_def< Materializer, Steps >
on_error_complete() (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
on_error_return(ErrorHandler error_handler) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
on_error_return_item(output_type item) (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
operator=(const observable_def &)=delete (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
operator=(observable_def &&)=default (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
output_type typedef (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
prefix_and_tail(size_t prefix_size) &&	caf::flow::observable_def< Materializer, Steps >
publish() &&	caf::flow::observable_def< Materializer, Steps >
reduce(Init init, Reducer reducer) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
sample(timespan period)	caf::flow::observable_def< Materializer, Steps >
scan(Init init, Scanner scanner) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
share(size_t subscriber_threshold=1) &&	caf::flow::observable_def< Materializer, Steps >
skip(size_t n) &&	caf::flow::observable_def< Materializer, Steps >
skip_last(size_t n) &&	caf::flow::observable_def< Materializer, Steps >
start_with(Input &&value) &&	caf::flow::observable_def< Materializer, Steps >
subscribe(Out &&out) &&	caf::flow::observable_def< Materializer, Steps >
sum() && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
take(size_t n) &&	caf::flow::observable_def< Materializer, Steps >
take_last(size_t n) &&	caf::flow::observable_def< Materializer, Steps >
take_while(Predicate predicate) && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
to_publisher() &&	caf::flow::observable_def< Materializer, Steps >
to_resource() &&	caf::flow::observable_def< Materializer, Steps >
to_resource(size_t buffer_size, size_t min_request_size) &&	caf::flow::observable_def< Materializer, Steps >
to_stream(cow_string name, timespan max_delay, size_t max_items_per_batch) &&	caf::flow::observable_def< Materializer, Steps >
to_stream(std::string name, timespan max_delay, size_t max_items_per_batch) &&	caf::flow::observable_def< Materializer, Steps >
to_typed_stream(cow_string name, timespan max_delay, size_t max_items_per_batch) &&	caf::flow::observable_def< Materializer, Steps >
to_typed_stream(std::string name, timespan max_delay, size_t max_items_per_batch) &&	caf::flow::observable_def< Materializer, Steps >
to_vector() && (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
transform(NewStep step) &&	caf::flow::observable_def< Materializer, Steps >
valid() const noexcept (defined in caf::flow::observable_def< Materializer, Steps >)	caf::flow::observable_def< Materializer, Steps >
zip_with(F fn, T0 input0, Ts... inputs)	caf::flow::observable_def< Materializer, Steps >