InfallibleType

Merges the specified observable sequences into one observable sequence by using the selector function whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence whenever any of the observable sequences produces an element.

Allows iterating over the values of an Infallible asynchronously via Swift’s concurrency features (async/await)

A sample usage would look like so:

for await value in observable.values {
    // Handle emitted values
}

Returns an infallible sequence that contains a single element.

Returns an infallible sequence that contains a single element.

Returns a non-terminating infallible sequence, which can be used to denote an infinite duration.

Returns an empty infallible sequence, using the specified scheduler to send out the single Completed message.

Returns an infallible sequence that invokes the specified factory function whenever a new observer subscribes.

Filters the elements of an observable sequence based on a predicate.

Projects each element of an observable sequence into a new form.

Projects each element of an observable sequence into an optional form and filters all optional results.

Returns an observable sequence that contains only distinct contiguous elements according to the keySelector.

Returns an observable sequence that contains only distinct contiguous elements according to the comparer.

Returns an observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.

Returns an observable sequence that contains only contiguous elements with distinct values in the provided key path on each object.

Ignores elements from an observable sequence which are followed by another element within a specified relative time duration, using the specified scheduler to run throttling timers.

Returns an Observable that emits the first and the latest item emitted by the source Observable during sequential time windows of a specified duration.

This operator makes sure that no two elements are emitted in less then dueTime.

Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence.

Projects each element of an observable sequence into a new sequence of observable sequences and then transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.

It is a combination of map + switchLatest operator

Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence. If element is received while there is some projected observable sequence being merged it will simply be ignored.

Concatenates the second observable sequence to self upon successful termination of self.

Concatenates all observable sequences in the given sequence, as long as the previous observable sequence terminated successfully.

This operator has tail recursive optimizations that will prevent stack overflow.

Optimizations will be performed in cases equivalent to following:

[1, [2, [3, …..].concat()].concat].concat()

Concatenates all observable sequences in the given collection, as long as the previous observable sequence terminated successfully.

This operator has tail recursive optimizations that will prevent stack overflow.

Optimizations will be performed in cases equivalent to following:

[1, [2, [3, …..].concat()].concat].concat()

Concatenates all observable sequences in the given collection, as long as the previous observable sequence terminated successfully.

This operator has tail recursive optimizations that will prevent stack overflow.

Optimizations will be performed in cases equivalent to following:

[1, [2, [3, …..].concat()].concat].concat()

Projects each element of an observable sequence to an observable sequence and concatenates the resulting observable sequences into one observable sequence.

Merges elements from all observable sequences from collection into a single observable sequence.

Merges elements from all infallible sequences from array into a single infallible sequence.

Merges elements from all infallible sequences into a single infallible sequence.

Applies an accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.

For aggregation behavior with no intermediate results, see reduce.

Applies an accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.

For aggregation behavior with no intermediate results, see reduce.

Prepends a value to an observable sequence.

Returns the elements from the source observable sequence until the other observable sequence produces an element.

Returns the elements from the source observable sequence until the other observable sequence produces an element.

Returns elements from an observable sequence until the specified condition is true.

Returns elements from an observable sequence as long as a specified condition is true.

Returns a specified number of contiguous elements from the start of an observable sequence.

Takes elements for the specified duration from the start of the infallible source sequence, using the specified scheduler to run timers.

Bypasses elements in an infallible sequence as long as a specified condition is true and then returns the remaining elements.

Returns the elements from the source infallible sequence that are emitted after the other infallible sequence produces an element.

Returns an observable sequence that shares a single subscription to the underlying sequence, and immediately upon subscription replays elements in buffer.

This operator is equivalent to:

• .whileConnected // Each connection will have it's own subject instance to store replay events. // Connections will be isolated from each another. source.multicast(makeSubject: { Replay.create(bufferSize: replay) }).refCount()
• .forever // One subject will store replay events for all connections to source. // Connections won't be isolated from each another. source.multicast(Replay.create(bufferSize: replay)).refCount()

It uses optimized versions of the operators for most common operations.

Provides an unretained, safe to use (i.e. not implicitly unwrapped), reference to an object along with the events emitted by the sequence.

In the case the provided object cannot be retained successfully, the sequence will complete.

Provides an unretained, safe to use (i.e. not implicitly unwrapped), reference to an object along with the events emitted by the sequence.

In the case the provided object cannot be retained successfully, the sequence will complete.

Merges two observable sequences into one observable sequence by combining each element from self with the latest element from the second source, if any.

Merges two observable sequences into one observable sequence by using latest element from the second sequence every time when self emits an element.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences have produced an element at a corresponding index.

Subscribes an element handler, a completion handler and disposed handler to an observable sequence.

Error callback is not exposed because Infallible can’t error out.

Also, take in an object and provide an unretained, safe to use (i.e. not implicitly unwrapped), reference to it along with the events emitted by the sequence.

Subscribes an element handler, a completion handler and disposed handler to an observable sequence.

Error callback is not exposed because Infallible can’t error out.

Subscribes an event handler to an observable sequence.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Merges the specified observable sequences into one observable sequence of tuples whenever any of the observable sequences produces an element.

Returns an observable sequence that contains only distinct contiguous elements according to equality operator.