| 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 > | |
| 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 > | |
| for_each(OnNext on_next, OnError on_error) | 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 > | |
| 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_backpressure_buffer(size_t buffer_size, backpressure_overflow_strategy strategy=backpressure_overflow_strategy::fail) | caf::flow::observable< T > | |
| on_error_complete() | caf::flow::observable< T > | |
| on_error_return(ErrorHandler error_handler) | caf::flow::observable< T > | |
| on_error_return_item(T item) | 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=(intrusive_ptr< Operator > ptr) 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 > | |
| parent() const | 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 > | |
| sample(timespan period) | caf::flow::observable< T > | |
| scan(Init init, Scanner scanner) | 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 > | |
| start_with(Input value) | 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_stream(cow_string name, timespan max_delay, size_t max_items_per_batch) | caf::flow::observable< T > | |
| to_stream(std::string name, timespan max_delay, size_t max_items_per_batch) | caf::flow::observable< T > | |
| to_typed_stream(cow_string name, timespan max_delay, size_t max_items_per_batch) | caf::flow::observable< T > | |
| to_typed_stream(std::string name, timespan max_delay, size_t max_items_per_batch) | 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 > | |
1.11.0