|
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++.
|
|
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++.
|
| ▼ Ix | |
| ▼ CPP | |
| ▼ src | |
| ▼ cpplinq | |
| linq.hpp | |
| linq_cursor.hpp | |
| linq_groupby.hpp | |
| linq_iterators.hpp | |
| linq_last.hpp | |
| linq_select.hpp | |
| linq_selectmany.hpp | |
| linq_skip.hpp | |
| linq_take.hpp | |
| linq_where.hpp | |
| util.hpp | |
| ▼ Rx | |
| ▼ v2 | |
| ▼ src | |
| ▼ rxcpp | |
| ► operators | |
| rx-all.hpp | Returns an Observable that emits true if every item emitted by the source Observable satisfies a specified condition, otherwise false. Emits true if the source Observable terminates without emitting any item |
| rx-amb.hpp | For each item from only the first of the given observables deliver from the new observable that is returned, on the specified scheduler |
| rx-any.hpp | Returns an Observable that emits true if any item emitted by the source Observable satisfies a specified condition, otherwise false. Emits false if the source Observable terminates without emitting any item |
| rx-buffer_count.hpp | Return an observable that emits connected, non-overlapping buffer, each containing at most count items from the source observable. If the skip parameter is set, return an observable that emits buffers every skip items containing at most count items from the source observable |
| rx-buffer_time.hpp | Return an observable that emits buffers every period time interval and collects items from this observable for period of time into each produced buffer. If the skip parameter is set, Return an observable that emits buffers every skip time interval and collects items from this observable for period of time into each produced buffer, on the specified scheduler |
| rx-buffer_time_count.hpp | Return an observable that emits connected, non-overlapping buffers of items from the source observable that were emitted during a fixed duration of time or when the buffer has reached maximum capacity (whichever occurs first), on the specified scheduler |
| rx-combine_latest.hpp | For each item from all of the observables select a value to emit from the new observable that is returned |
| rx-concat.hpp | For each item from this observable subscribe to one at a time, in the order received. For each item from all of the given observables deliver from the new observable that is returned |
| rx-concat_map.hpp | 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 |
| rx-connect_forever.hpp | Takes a connectable_observable source and calls connect during the construction of the expression. This means that the source starts running without any subscribers and continues running after all subscriptions have been unsubscribed |
| rx-debounce.hpp | Return an observable that emits an item if a particular timespan has passed without emitting another item from the source observable |
| rx-delay.hpp | Return an observable that emits each item emitted by the source observable after the specified delay |
| rx-distinct.hpp | For each item from this observable, filter out repeated values and emit only items that have not already been emitted |
| rx-distinct_until_changed.hpp | For each item from this observable, filter out consequentially repeated values and emit only changes from the new observable that is returned |
| rx-element_at.hpp | Pulls an item located at a specified index location in the sequence of items and emits that item as its own sole emission |
| rx-filter.hpp | For each item from this observable use Predicate to select which items to emit from the new observable that is returned |
| rx-finally.hpp | Add a new action at the end of the new observable that is returned |
| rx-flat_map.hpp | 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 |
| rx-group_by.hpp | Return an observable that emits grouped_observables, each of which corresponds to a unique key value and each of which emits those items from the source observable that share that key value |
| rx-ignore_elements.hpp | Do not emit any items from the source Observable, but allow termination notification (either onError or onCompleted) to pass through unchanged |
| rx-lift.hpp | Takes any function that will take a subscriber for this observable and produce a subscriber. this is intended to allow externally defined operators, that use make_subscriber, to be connected into the expression |
| rx-map.hpp | For each item from this observable use Selector to produce an item to emit from the new observable that is returned |
| rx-merge.hpp | For each given observable subscribe. For each item emitted from all of the given observables, deliver from the new observable that is returned |
| rx-multicast.hpp | Allows connections to the source to be independent of subscriptions |
| rx-observe_on.hpp | All values are queued and delivered using the scheduler from the supplied coordination |
| rx-on_error_resume_next.hpp | If an error occurs, take the result from the Selector and subscribe to that instead |
| rx-pairwise.hpp | Take values pairwise from this observable |
| rx-publish.hpp | Turn a cold observable hot and allow connections to the source to be independent of subscriptions. Turn a cold observable hot, send the most recent value to any new subscriber, and allow connections to the source to be independent of subscriptions |
| rx-reduce.hpp | For each item from this observable use Accumulator to combine items, when completed use ResultSelector to produce a value that will be emitted from the new observable that is returned |
| rx-ref_count.hpp | Takes a connectable_observable source and uses a ref_count of the subscribers to control the connection to the published source. The first subscription will cause a call to connect() and the last unsubscribe will unsubscribe the connection |
| rx-repeat.hpp | Repeat this observable for the given number of times or infinitely |
| rx-replay.hpp | 1) replay(optional Coordination, optional CompositeSubscription) Turn a cold observable hot, send all earlier emitted values to any new subscriber, and allow connections to the source to be independent of subscriptions |
| rx-retry-repeat-common.hpp | Implementation commonalities between retry and repeat operators abstracted away from rx-retry.hpp and rx-repeat.hpp files. Should be used only from rx-retry.hpp and rx-repeat.hpp |
| rx-retry.hpp | Retry this observable for the given number of times |
| rx-sample_time.hpp | Return an Observable that emits the most recent items emitted by the source Observable within periodic time intervals |
| rx-scan.hpp | For each item from this observable use Accumulator to combine items into a value that will be emitted from the new observable that is returned |
| rx-sequence_equal.hpp | Determine whether two Observables emit the same sequence of items |
| rx-skip.hpp | Make new observable with skipped first count items from this observable |
| rx-skip_last.hpp | Make new observable with skipped last count items from this observable |
| rx-skip_until.hpp | Make new observable with items skipped until on_next occurs on the trigger observable or until the specified time. skip_until takes (TriggerObservable, optional Coordination) or (TimePoint, optional Coordination) |
| rx-start_with.hpp | Start with the supplied values, then concatenate this observable |
| rx-subscribe.hpp | Subscribe will cause the source observable to emit values to the provided subscriber |
| rx-subscribe_on.hpp | Subscription and unsubscription are queued and delivered using the scheduler from the supplied coordination |
| rx-switch_if_empty.hpp | If the source Observable terminates without emitting any items, emits items from a backup Observable |
| rx-switch_on_next.hpp | Return observable that emits the items emitted by the observable most recently emitted by the source observable |
| rx-take.hpp | For the first count items from this observable emit them from the new observable that is returned |
| rx-take_last.hpp | Emit only the final t items emitted by the source Observable |
| rx-take_until.hpp | For each item from this observable until on_next occurs on the trigger observable or until the specified time, emit them from the new observable that is returned. take_until takes (TriggerObservable, optional Coordination) or (TimePoint, optional Coordination) |
| rx-take_while.hpp | For the first items fulfilling the predicate from this observable emit them from the new observable that is returned |
| rx-tap.hpp | Inspect calls to on_next, on_error and on_completed |
| rx-time_interval.hpp | Returns an observable that emits indications of the amount of time lapsed between consecutive emissions of the source observable. The first emission from this new Observable indicates the amount of time lapsed between the time when the observer subscribed to the Observable and the time when the source Observable emitted its first item |
| rx-timeout.hpp | Return an observable that terminates with timeout_error if a particular timespan has passed without emitting another item from the source observable |
| rx-timestamp.hpp | Returns an observable that attaches a timestamp to each item emitted by the source observable indicating when it was emitted |
| rx-window.hpp | Return an observable that emits connected, non-overlapping windows, each containing at most count items from the source observable. If the skip parameter is set, return an observable that emits windows every skip items containing at most count items from the source observable |
| rx-window_time.hpp | Return an observable that emits observables every period time interval and collects items from this observable for period of time into each produced observable, on the specified scheduler. If the skip parameter is set, return an observable that emits observables every skip time interval and collects items from this observable for period of time into each produced observable, on the specified scheduler |
| rx-window_time_count.hpp | Return an observable that emits connected, non-overlapping windows of items from the source observable that were emitted during a fixed duration of time or when the window has reached maximum capacity (whichever occurs first), on the specified scheduler |
| rx-window_toggle.hpp | Return an observable that emits observables every period time interval and collects items from this observable for period of time into each produced observable, on the specified scheduler |
| rx-with_latest_from.hpp | For each item from the first observable select the latest value from all the observables to emit from the new observable that is returned |
| rx-zip.hpp | Bring by one item from all given observables and select a value to emit from the new observable that is returned |
| ► schedulers | |
| rx-currentthread.hpp | |
| rx-eventloop.hpp | |
| rx-immediate.hpp | |
| rx-newthread.hpp | |
| rx-runloop.hpp | |
| rx-sameworker.hpp | |
| rx-test.hpp | |
| rx-virtualtime.hpp | |
| ► sources | |
| rx-create.hpp | Returns an observable that executes the specified function when a subscriber subscribes to it |
| rx-defer.hpp | Returns an observable that calls the specified observable factory to create an observable for each new observer that subscribes |
| rx-empty.hpp | Returns an observable that sends no items to observer and immediately completes, on the specified scheduler |
| rx-error.hpp | Returns an observable that sends no items to observer and immediately generates an error, on the specified scheduler |
| rx-interval.hpp | Returns an observable that emits a sequential integer every specified time interval, on the specified scheduler |
| rx-iterate.hpp | Returns an observable that sends each value in the collection, on the specified scheduler |
| rx-never.hpp | |
| rx-range.hpp | Returns an observable that sends values in the range first-last by adding step to the previous value. The values are sent on the specified scheduler |
| rx-scope.hpp | Returns an observable that makes an observable by the specified observable factory using the resource provided by the specified resource factory for each new observer that subscribes |
| rx-timer.hpp | Returns an observable that emits an integer at the specified time point |
| ► subjects | |
| rx-behavior.hpp | |
| rx-replaysubject.hpp | |
| rx-subject.hpp | |
| rx-synchronize.hpp | |
| rx-connectable_observable.hpp | |
| rx-coordination.hpp | |
| rx-coroutine.hpp | The proposal to add couroutines to the standard adds co_await, for co_await, co_yield and co_return. This file adds begin(observable<>) & end(observable<>) which enables for co_await to work with the observable<> type |
| rx-grouped_observable.hpp | |
| rx-includes.hpp | |
| rx-lite.hpp | |
| rx-notification.hpp | |
| rx-observable.hpp | |
| rx-observer.hpp | |
| rx-operators.hpp | |
| rx-predef.hpp | |
| rx-scheduler.hpp | |
| rx-sources.hpp | |
| rx-subjects.hpp | |
| rx-subscriber.hpp | |
| rx-subscription.hpp | |
| rx-test.hpp | |
| rx-trace.hpp | |
| rx-util.hpp | |
| rx.hpp |
1.8.11
