Struct rxrust::ops::finalize::FinalizeOp[−][src]

pub struct FinalizeOp<S, F> { /* fields omitted */ }

Trait Implementations

Returns a copy of the value. Read more

Performs copy-assignment from source. Read more

emit only the first item emitted by an Observable

emit only the first item emitted by an Observable

Emit only the last final item emitted by a source observable or a default item given. Read more

Emit only item n (0-indexed) emitted by an Observable

Do not emit any items from an Observable but mirror its termination notification Read more

Determine whether all items emitted by an Observable meet some criteria

Determine whether an Observable emits a particular item or not

Emits only last final item emitted by a source observable. Read more

Call a function when observable completes, errors or is unsubscribed from.

Creates an Observable that combines all the emissions from Observables that get emitted from an Observable. Read more

Applies given function to each item emitted by this Observable, where that function returns an Observable that itself emits items. It then merges the emissions of these resulting Observables, emitting these merged results as its own sequence. Read more

Groups items emited by the source Observable into Observables. Each emited Observable emits items matching the key returned by the discriminator function. Read more

Creates a new stream which calls a closure on each element and uses its return as the value. Read more

Maps emissions to a constant value.

combine two Observables into one by merging their emissions Read more

Converts a higher-order Observable into a first-order Observable which concurrently delivers all values that are emitted on the inner Observables. Read more

Emit only those items from an Observable that pass a predicate test Read more

The closure must return an Option. filter_map creates an iterator which calls this closure on each element. If the closure returns Some(element), then that element is returned. If the closure returns None, it will try again, and call the closure on the next element, seeing if it will return Some. Read more

box an observable to a safety object and convert it to a simple type BoxOp, which only care Item and Err Observable emitted. Read more

Ignore the first count values emitted by the source Observable. Read more

Ignore values while result of a callback is true. Read more

Ignore the last count values emitted by the source Observable. Read more

Emits only the first count values emitted by the source Observable. Read more

Emits the values emitted by the source Observable until a notifier Observable emits a value. Read more

Emits values while result of an callback is true. Read more

Emits only the last count values emitted by the source Observable. Read more

Emits item it has most recently emitted since the previous sampling Read more

The Scan operator applies a function to the first item emitted by the source observable and then emits the result of that function as its own first emission. It also feeds the result of the function back into the function along with the second item emitted by the source observable in order to generate its second emission. It continues to feed back its own subsequent emissions along with the subsequent emissions from the source Observable in order to create the rest of its sequence. Read more

Works like scan_initial but starts with a value defined by a Default trait for the first argument binary_op operator operates on. Read more

Apply a function to each item emitted by an observable, sequentially, and emit the final value, after source observable completes. Read more

Works like reduce_initial but starts with a value defined by a Default trait for the first argument f operator operates on. Read more

Emits the item from the source observable that had the maximum value. Read more

Emits the item from the source observable that had the minimum value. Read more

Calculates the sum of numbers emitted by an source observable and emits this sum when source completes. Read more

Emits the number of items emitted by a source observable when this source completes. Read more

Calculates the sum of numbers emitted by an source observable and emits this sum when source completes. Read more

Returns a ConnectableObservable. A ConnectableObservable Observable resembles an ordinary Observable, except that it does not begin emitting items when it is subscribed to, but only when the Connect operator is applied to it. In this way you can wait for all intended observers to subscribe to the Observable before the Observable begins emitting items. Read more

Returns a new Observable that multicast (shares) the original Observable. As long as there is at least one Subscriber this Observable will be subscribed and emitting data. When all subscribers have unsubscribed it will unsubscribe from the source Observable. Because the Observable is multicasting it makes the stream hot. This is an alias for publish().ref_count() Read more

Delays the emission of items from the source Observable by a given timeout or until a given Instant. Read more

Specify the Scheduler on which an Observable will operate Read more

Re-emits all notifications from source Observable with specified scheduler. Read more

Emits a value from the source Observable only after a particular time span has passed without another source emission. Read more

Emits a value from the source Observable, then ignores subsequent source values for duration milliseconds, then repeats this process. Read more

Returns an Observable that emits all items emitted by the source Observable that are distinct by comparison from previous items. Read more

‘Zips up’ two observable into a single observable of pairs. Read more

Emits default value if Observable completed with empty result Read more

Buffers emitted values of type T in a Vec and emits that Vec as soon as the buffer’s size equals the given count. On complete, if the buffer is not empty, it will be emitted. On error, the buffer will be discarded. Read more

Buffers emitted values of type T in a Vec and emits that Vec periodically. Read more

Buffers emitted values of type T in a Vec and emits that Vec either if the buffer’s size equals count, or periodically. This operator combines the functionality of buffer_with_count and buffer_with_time. Read more

Convert to a thread-safe mode.

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Performs the conversion.

Performs the conversion.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

🔬 This is a nightly-only experimental API. (toowned_clone_into)

recently added

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.