Instance Operators

Use this page to find the instance operator implemented by the type that fits your needs:

Instance methods

Using an existing sequence

I want to change each value

I want to pull a property off each value

I want to be notified of values without affecting them

I want to include values

based on custom logic

from the start of the sequence

based on custom logic

from the end of the sequence

until another sequence emits a value or completes

I want to ignore values

altogether

from the start of the sequence

based on custom logic

from the end of the sequence

until another sequence emits a value

that have the same value as the previous

that occur too frequently

I want to compute

the sum

of its values

the average

using custom logic

and only output the final value

and output the values as they are calculated

I want to wrap its messages with metadata

that describes each message

that includes the time past since the last value

that includes a timestamp

after a period of inactivity

I want to throw an error

I want to switch to another sequence

I want ensure there is only one value

and throw an error if there are more or less than one value

and use the default value if there are no values

I want to only take the first value

and throw an error if there are no values

and use the default value if there are no values

within a time period

I want to only take the last value

and error if there are no values

and use the default value if there are no values

I want to know how many values it contains

I want to know if it includes a value

I want to know if a condition is satisfied

by any of its values

by all of its values

I want to delay messages by a specific amount of time

based on custom logic

I want to group the values

until the sequence completes

using custom logic

as arrays

as sequences

in batches of a particular size

as arrays

as sequences

based on time

as arrays

as sequences

based on time or count, whichever happens first

as arrays

as sequences

based on a key

until the sequence completes

and control the lifetime of each group

I want to start a new sequence for each value

and emit the values from all sequences in parallel

and emit the values from each sequence in order

and cancel the previous sequence when a new value arrives

and recursively start a new sequence for each new value

and emit values from all sequences depending for onNext, onError, and onCompleted in parallel

and emit values from all sequences depending for onNext, onError, and onCompleted in order

I want to combine it with another

And be notified when both have completed

I want to perform complex operations without breaking the fluent calls

I want to share a subscription between multiple subscribers

using a specific subject implementation

and supply the last value to future subscribers

and replay a default or the latest value to future subscribers

and replay n number of values to future subscribers

when an error occurs

I want to re-subscribe

I want to start a new sequence

that depends on the error

when it completes

I want to re-subscribe

I want to start a new sequence

when it completes or errors

I want to start a new sequence

when it completes, errors or unsubscribes

I want to execute a function

I want to change the scheduler that routes

calls to subscribe

messages

Using two sequences

I want to decide which to receive values from

based on which one has values first

I want to determine if their values are equal

I want to combine their values

only when the first sequence emits, using the latest value from each

in order

reusing the latest value when unchanged

using each value only once

that share overlapping “lifetime” that I choose

and be notified for each combination

and be given a sequence of “rights” for each “left”

I want to include values from both

Instance Operators

See Also ##

See Also ##