caf::flow::observable< T > Member List

This is the complete list of members for caf::flow::observable< T >, including all inherited members.

as_observable() const &noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
as_observable() &&noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
buffer(size_t count)	caf::flow::observable< T >
buffer(size_t count, timespan period)	caf::flow::observable< T >
collect_batches(timespan max_delay, size_t max_items)	caf::flow::observable< T >
compose(Fn &&fn) &	caf::flow::observable< T >
compose(Fn &&fn) &&	caf::flow::observable< T >
concat(Inputs &&...)	caf::flow::observable< T >
concat(Inputs &&... xs) (defined in caf::flow::observable< T >)	caf::flow::observable< T >
concat_map(F f)	caf::flow::observable< T >
ctx() const	caf::flow::observable< T >
distinct()	caf::flow::observable< T >
do_finally(F f)	caf::flow::observable< T >
do_on_complete(F f)	caf::flow::observable< T >
do_on_error(F f)	caf::flow::observable< T >
do_on_next(F f)	caf::flow::observable< T >
element_at(size_t n)	caf::flow::observable< T >
filter(Predicate prediate)	caf::flow::observable< T >
first()	caf::flow::observable< T >
flat_map(F f)	caf::flow::observable< T >
for_each(OnNext on_next)	caf::flow::observable< T >
head_and_tail()	caf::flow::observable< T >
ignore_elements()	caf::flow::observable< T >
ignore_t typedef	caf::flow::observable< T >
last()	caf::flow::observable< T >
make_observable(CoordinatorType *ctx, Ts &&... xs)	caf::flow::observable< T >	related
map(F f)	caf::flow::observable< T >
merge(Inputs &&... xs)	caf::flow::observable< T >
observable(pimpl_type pimpl) noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >	explicit
observable() noexcept=default (defined in caf::flow::observable< T >)	caf::flow::observable< T >
observable(observable &&) noexcept=default (defined in caf::flow::observable< T >)	caf::flow::observable< T >
observable(const observable &) noexcept=default (defined in caf::flow::observable< T >)	caf::flow::observable< T >
observe_on(coordinator *other, size_t buffer_size, size_t min_request_size)	caf::flow::observable< T >
observe_on(coordinator *other)	caf::flow::observable< T >
on_error_complete()	caf::flow::observable< T >
operator bool() const noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >	explicit
operator!() const noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
operator=(std::nullptr_t) noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
operator=(observable &&) noexcept=default (defined in caf::flow::observable< T >)	caf::flow::observable< T >
operator=(const observable &) noexcept=default (defined in caf::flow::observable< T >)	caf::flow::observable< T >
output_type typedef	caf::flow::observable< T >
pimpl() const &noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
pimpl() &&noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
pimpl_type typedef	caf::flow::observable< T >
prefix_and_tail(size_t prefix_size)	caf::flow::observable< T >
publish()	caf::flow::observable< T >
reduce(Init init, Reducer reducer)	caf::flow::observable< T >
share(size_t subscriber_threshold=1)	caf::flow::observable< T >
skip(size_t n)	caf::flow::observable< T >
skip_last(size_t n)	caf::flow::observable< T >
subscribe(observer< T > what)	caf::flow::observable< T >
subscribe(async::producer_resource< T > resource)	caf::flow::observable< T >
subscribe(ignore_t)	caf::flow::observable< T >
sum()	caf::flow::observable< T >
swap(observable &other) (defined in caf::flow::observable< T >)	caf::flow::observable< T >
take(size_t n)	caf::flow::observable< T >
take_last(size_t n)	caf::flow::observable< T >
take_while(Predicate prediate)	caf::flow::observable< T >
to_publisher()	caf::flow::observable< T >
to_resource(size_t buffer_size, size_t min_request_size)	caf::flow::observable< T >
to_resource()	caf::flow::observable< T >
to_vector()	caf::flow::observable< T >
transform(Step step)	caf::flow::observable< T >
valid() const noexcept (defined in caf::flow::observable< T >)	caf::flow::observable< T >
zip_with(F fn, T0 input0, Ts... inputs)	caf::flow::observable< T >