Publishers.SwitchToLatest

Creates a publisher that “flattens” nested publishers.

The publisher from which this publisher receives elements.

Publishes a single Boolean value that indicates whether all received elements pass a given predicate.

Append the output of a publisher with the specified sequence.

Raises a fatal error when its upstream publisher fails, and otherwise republishes all received input.

Assigns a publisher’s output to a property of an object.

Raises a debugger signal when a provided closure needs to stop the process in the debugger.

Raises a debugger signal upon receiving a failure.

Buffers elements received from an upstream publisher.

Handles errors from an upstream publisher by replacing it with another publisher.

Collects all received elements, and emits a single array of the collection when the upstream publisher finishes.

Collects up to the specified number of elements, and then emits a single array of the collection.

Collects elements by a given strategy, and emits a single array of the collection.

Subscribes to an additional publisher and publishes a tuple upon receiving output from either publisher.

Subscribes to two additional publishers and publishes a tuple upon receiving output from any of the publishers.

Subscribes to an additional publisher and invokes a closure upon receiving output from either publisher.

Subscribes to three additional publishers and publishes a tuple upon receiving output from any of the publishers.

Subscribes to two additional publishers and invokes a closure upon receiving output from any of the publishers.

Subscribes to three additional publishers and invokes a closure upon receiving output from any of the publishers.

Calls a closure with each received element and publishes any returned optional that has a value.

Publishes a Boolean value upon receiving an element equal to the argument.

Publishes a Boolean value upon receiving an element that satisfies the predicate closure.

Publishes the number of elements received from the upstream publisher.

Publishes elements only after a specified time interval elapses between events.

Decodes the output from upstream using a specified decoder.

Delays delivery of all output to the downstream receiver by a specified amount of time on a particular scheduler.

Ignores elements from the upstream publisher until it receives an element from a second publisher.

Omits elements from the upstream publisher until a given closure returns false, before republishing all remaining elements.

Omits the specified number of elements before republishing subsequent elements.

Encodes the output from upstream using a specified encoder.

Wraps this publisher with a type eraser.

Republishes all elements that match a provided closure.

Publishes the first element of a stream, then finishes.

Publishes the first element of a stream to satisfy a predicate closure, then finishes.

Transforms all elements from an upstream publisher into a new or existing publisher.

Performs the specified closures when publisher events occur.

Ingores all upstream elements, but passes along a completion state (finished or failed).

Publishes only the last element of a stream, after the stream finishes.

Publishes only the last element of a stream that satisfies a predicate closure, after the stream finishes.

Creates a connectable wrapper around the publisher.

Transforms all elements from the upstream publisher with a provided closure.

Publishes the value of a key path.

Publishes the values of two key paths as a tuple.

Publishes the values of three key paths as a tuple.

Converts any failure from the upstream publisher into a new error.

Publishes the maximum value received from the upstream publisher, after it finishes.

Publishes the maximum value received from the upstream publisher, using the provided ordering closure.

Measures and emits the time interval between events received from an upstream publisher.

Combines elements from this publisher with those from another publisher of the same type, delivering an interleaved sequence of elements.

Combines elements from this publisher with those from two other publishers, delivering an interleaved sequence of elements.

Combines elements from this publisher with those from three other publishers, delivering an interleaved sequence of elements.

Combines elements from this publisher with those from four other publishers, delivering an interleaved sequence of elements.

Combines elements from this publisher with those from five other publishers, delivering an interleaved sequence of elements.

Combines elements from this publisher with those from six other publishers, delivering an interleaved sequence of elements.

Combines elements from this publisher with those from seven other publishers, delivering an interleaved sequence of elements.

Publishes the minimum value received from the upstream publisher, after it finishes.

Publishes the minimum value received from the upstream publisher, after it finishes.

Applies a closure to create a subject that delivers elements to subscribers.

Provides a subject to deliver elements to multiple subscribers.

Publishes a specific element, indicated by its index in the sequence of published elements.

Publishes elements specified by their range in the sequence of published elements.

Republishes elements up to the specified maximum count.

Republishes elements until another publisher emits an element.

Republishes elements while a predicate closure indicates publishing should continue.

Prefixes the output of a publisher with the specified sequence.

Prints log messages for all publishing events.

Specifies the scheduler on which to receive elements from the publisher.

Applies a closure that accumulates each element of a stream and publishes a final result upon completion.

Publishes only elements that don’t match the previous element.

Publishes only elements that don’t match the previous element, as evaluated by a provided closure.

Replaces an empty stream with the provided element.

Replaces any errors in the stream with the provided element.

Replaces nil elements in the stream with the provided element.

Attempts to recreate a failed subscription with the upstream publisher using a specified number of attempts to establish the connection.

Transforms elements from the upstream publisher by providing the current element to a closure along with the last value returned by the closure.

Changes the failure type declared by the upstream publisher.

Returns a publisher as a class instance.

Attaches a subscriber with closure-based behavior.

Attaches a subscriber with closure-based behavior to a publisher that never fails.

Attaches the specified subject to this publisher.

Attaches the specified subscriber to this publisher.

Specifies the scheduler on which to perform subscribe, cancel, and request operations.

Flattens the stream of events from multiple upstream publishers to appear as if they were coming from a single stream of events.

Publishes either the most-recent or first element published by the upstream publisher in the specified time interval.

Terminates publishing if the upstream publisher exceeds the specified time interval without producing an element.

Publishes a single Boolean value that indicates whether all received elements pass a given error-throwing predicate.

Handles errors from an upstream publisher by replacing it with another publisher or an error.

Calls an error-throwing closure with each received element and publishes any returned optional that has a value.

Publishes a Boolean value upon receiving an element that satisfies the throwing predicate closure.

Omits elements from the upstream publisher until an error-throwing closure returns false, before republishing all remaining elements.

Republishes all elements that match a provided error-throwing closure.

Publishes the first element of a stream to satisfy a throwing predicate closure, then finishes.

Publishes only the last element of a stream that satisfies an error-throwing predicate closure, after the stream finishes.

Transforms all elements from the upstream publisher with a provided error-throwing closure.

Publishes the maximum value received from the upstream publisher, using the provided error-throwing closure to order the items.

Publishes the minimum value received from the upstream publisher, using the provided error-throwing closure to order the items.

Republishes elements while a error-throwing predicate closure indicates publishing should continue.

Applies an error-throwing closure that accumulates each element of a stream and publishes a final result upon completion.

Publishes only elements that don’t match the previous element, as evaluated by a provided error-throwing closure.

Transforms elements from the upstream publisher by providing the current element to an error-throwing closure along with the last value returned by the closure.

Combines elements from another publisher and deliver pairs of elements as tuples.

Combines elements from two other publishers and delivers groups of elements as tuples.

Combines elements from another publisher and delivers a transformed output.

Combines elements from three other publishers and delivers groups of elements as tuples.

Combines elements from two other publishers and delivers a transformed output.

Combines elements from three other publishers and delivers a transformed output.