Observable Operators

These observable operators are the core of the Rx framework. These operate on observable sequences, which are sequences that invoke an event when a new data element is available.

Observable sequence sources do not take observable sequence(s) as input, but produce an observable sequence as output:

• Create - Note that this operator is being considered for renaming in a future revision.
• CreateWithDisposable - Note that this operator is being considered for renaming in a future revision.
• Defer - See Rx In Depth 13 - Hot and Cold Observables (3:32).
• Empty - See Rx in Depth 6: Primitives - Never, Empty, Return, and Throw (1:48).
• FromAsyncPattern
• FromEvent
• Generate
• GenerateInSequence
• Interval
• Never - See Rx in Depth 6: Primitives - Never, Empty, Return, and Throw (1:48).
• Range
• Repeat
• Return - See Rx in Depth 6: Primitives - Never, Empty, Return, and Throw (1:48).
• Start
• StartWith
• Throw - See Rx in Depth 6: Primitives - Never, Empty, Return, and Throw (1:48).
• Timer
• Using

Observable sequence operators take observable sequence(s) as input, and produce observable sequence(s) as output:

• Amb
• Asynchronous
• Buffer
• BufferWithTime
• Catch - See Rx In Depth 12: Concat, Catch, and OnErrorResumeNext (2:56).
• CombineLatest - See Rx in Depth 11: CombineLatest - combination semantics (3:44) and Rx in Depth 10: Zip - completion semantics (1:51) (CombineLatest has the same completion semantics as Zip).
• Concat - See Rx In Depth 12: Concat, Catch, and OnErrorResumeNext (2:56).
• Delay
• Dematerialize
• Do
• Finally
• GroupBy
• Hide
• HoldUntilChanged
• Let
• Materialize
• Merge - See Rx in Depth 8: Merge (2:36).
• ObserveOn
• ObserveOnDispatcher
• OnErrorResumeNext - See Rx In Depth 12: Concat, Catch, and OnErrorResumeNext (2:56).
• Remotable
• RemoveTimeInterval
• RemoveTimestamp
• Repeat - See Rx In Depth 14 - Repeat (2:10).
• Retry - See Rx In Depth 15 - Retry (2:03).
• Sample
• Scan
• Select - See Rx in Depth 2: Marble Diagrams; Select and Where (4:49).
• SelectMany - See Rx in Depth 3: SelectMany (4:21).
• Skip
• SkipWhile
• SubscribeOn
• SubscribeOnDispatcher
• Switch
• Synchronize
• Take
• TakeWhile
• Throttle
• TimeInterval
• Timeout
• Timestamp
• Until - See Rx in Depth 4: Until and WaitUntil (5:29).
• WaitUntil - See Rx in Depth 4: Until and WaitUntil (5:29).
• Where - See Rx in Depth 2: Marble Diagrams; Select and Where (4:49).
• Yield
• Zip - See Rx in Depth 9: Zip - combination semantics (2:35) and Rx in Depth 10: Zip - completion semantics (1:51).

Observable sequence evaluators take observable sequence(s) as input, but do not produce observable sequence(s) as output:

• Aggregate
• And
• Contains
• Count
• First
• FirstOrDefault
• GetEnumerator
• Last
• LastOrDefault
• Latest
• LatestValue
• LongCount
• MostRecent
• MostRecentValue
• Next
• NextValue
• Single
• SingleOrDefault
• ToEnumerable

Observable sequences also have join-based operations:

• ForkJoin
• Join
• Then

These operations are not yet understood well enough to fall into one of the categories above:

• Prune
• Publish
• Record
• Replay