Injects a side effect into a change set observable.

Adds a key to the change set result which enables all observable cache features of dynamic data.

Apply a logical And operator between the collections. Items which are in all of the sources are included in the result.

Apply a logical And operator between the collections. Items which are in all of the sources are included in the result.

Dynamically apply a logical And operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Dynamically apply a logical And operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Dynamically apply a logical And operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Converts the source observable to an read only observable list.

Converts the source list to an read only observable list.

Automatically refresh downstream operators when properties change.

Automatically refresh downstream operators when any property changes.

Automatically refresh downstream operator. The refresh is triggered when the observable receives a notification.

Binds a clone of the observable change set to the target observable collection.

Creates a binding to a readonly observable collection which is specified as an 'out' parameter.

Batches the underlying updates if a pause signal (i.e when the buffer selector return true) has been received. When a resume signal has been received the batched updates will be fired.

Batches the underlying updates if a pause signal (i.e when the buffer selector return true) has been received. When a resume signal has been received the batched updates will be fired.

Batches the underlying updates if a pause signal (i.e when the buffer selector return true) has been received. When a resume signal has been received the batched updates will be fired.

Batches the underlying updates if a pause signal (i.e when the buffer selector return true) has been received. When a resume signal has been received the batched updates will be fired.

Buffers changes for an initial period only. After the period has elapsed, not further buffering occurs.

Cast the changes to another form.

Cast the changes to another form Alas, I had to add the converter due to type inference issues. The converter can be avoided by CastToObject() first.

Cast the underlying type of an object. Use before a Cast function.

Clones the target list as a side effect of the stream.

Convert the object using the specified conversion function. This is a lighter equivalent of Transform and is designed to be used with non-disposable objects.

Defer the subscription until the stream has been inflated with data.

Defer the subscription until the cache has been inflated with data.

Disposes each item when no longer required. Individual items are disposed when removed or replaced. All items are disposed when the stream is disposed.

Selects distinct values from the source, using the specified value selector.

Apply a logical Except operator between the collections. Items which are in the source and not in the others are included in the result.

Apply a logical Except operator between the collections. Items which are in the source and not in the others are included in the result.

Dynamically apply a logical Except operator. Items from the first observable list are included when an equivalent item does not exist in the other sources.

Dynamically apply a logical Except operator. Items from the first observable list are included when an equivalent item does not exist in the other sources.

Dynamically apply a logical Except operator. Items from the first observable list are included when an equivalent item does not exist in the other sources.

Removes items from the cache according to the value specified by the time selector function.

Removes items from the cache according to the value specified by the time selector function.

Filters the source using the specified valueSelector.

Filters source using the specified filter observable predicate.

Filters source on the specified observable property using the specified predicate. The filter will automatically reapply when a property changes.

Filters source on the specified property using the specified predicate. The filter will automatically reapply when a property changes.

Convert the result of a buffer operation to a change set.

Provides a call back for each item change.

Provides a call back for each item change. Range changes are flattened, so there is only need to check for Add, Replace, Remove and Clear.

Groups the source on the value returned by group selector factory. The groupings contains an inner observable list.

Groups the source using the property specified by the property selector. The resulting groupings contains an inner observable list. Groups are re-applied when the property value changed. When there are likely to be a large number of group property changes specify a throttle to improve performance.

Groups the source using the property specified by the property selector. The resulting groupings are immutable. Groups are re-applied when the property value changed. When there are likely to be a large number of group property changes specify a throttle to improve performance.

Groups the source on the value returned by group selector factory. Each update produces immutable grouping.

Limits the size of the source cache to the specified limit. Notifies which items have been removed from the source list.

Dynamically merges the observable which is selected from each item in the stream, and un-merges the item when it is no longer part of the stream.

Prevents an empty notification.

Callback for each item as and when it is being added to the stream.

Callback for each item as and when it is being removed from the stream.

Apply a logical Or operator between the collections. Items which are in any of the sources are included in the result.

Apply a logical Or operator between the collections. Items which are in any of the sources are included in the result.

Dynamically apply a logical Or operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Dynamically apply a logical Or operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Dynamically apply a logical Or operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Applies paging to the data source.

list.

The latest copy of the cache is exposed for querying i) after each modification to the underlying data ii) upon subscription.

The latest copy of the cache is exposed for querying after each modification to the underlying data.

List equivalent to Publish().RefCount(). The source is cached so long as there is at least 1 subscriber.

Removes the index from all changes. NB: This operator has been introduced as a temporary fix for creating an Or operator using merge many.

Reverse sort of the change set.

Defer the subscription until loaded and skip initial change set.

Sorts the sequence using the specified comparer.

Sorts the sequence using the specified observable comparer.

Prepends an empty change set to the source.

Subscribes to each item when it is added to the stream and unsubscribes when it is removed. All items will be unsubscribed when the stream is disposed.

Suppress refresh notifications.

Transforms an observable sequence of observable changes sets into an observable sequence producing values only from the most recent observable sequence. Each time a new inner observable sequence is received, unsubscribe from the previous inner observable sequence and clear the existing result set.

Transforms an observable sequence of observable lists into a single sequence producing values only from the most recent observable sequence. Each time a new inner observable sequence is received, unsubscribe from the previous inner observable sequence and clear the existing result set.

Converts the change set into a fully formed collection. Each change in the source results in a new collection.

Converts the observable to an observable change set, allowing size to be specified. Change set observes observable change events.

Converts the observable to an observable change set, allowing size and time limit to be specified. Change set observes observable change events.

Converts the observable to an observable change set, allowing size and time limit to be specified. Change set observes observable change events.

Converts the observable to an observable change set. Change set observes observable change events.

Converts the observable to an observable change set, allowing time expiry to be specified. Change set observes observable change events.

Converts the observable to an observable change set, allowing size and time limit to be specified. Change set observes observable change events.

Converts the observable to an observable change set, with a specified limit of how large the list can be. Change set observes observable change events.

Converts the observable to an observable change set. Change set observes observable change events.

Limits the size of the result set to the specified number of items.

Converts the change set into a fully formed sorted collection. Each change in the source results in a new sorted collection.

Converts the change set into a fully formed sorted collection. Each change in the source results in a new sorted collection.

Projects each update item to a new form using the specified transform function.

Projects each update item to a new form using the specified transform function *** Annoyingly when using this overload you will have to explicitly specify the generic type arguments as type inference fails.

Projects each update item to a new form using the specified transform function. *** Annoyingly when using this overload you will have to explicitly specify the generic type arguments as type inference fails.

Projects each update item to a new form using the specified transform function.

Projects each update item to a new form using the specified transform function.

Equivalent to a select many transform. To work, the key must individually identify each child.

Flatten the nested observable list, and observe subsequent observable collection changes.

Flatten the nested observable collection, and observe subsequently observable collection changes.

Flatten the nested observable collection, and observe subsequently observable collection changes.

Virtualises the source using parameters provided via the requests observable.

Watches each item in the collection and notifies when any of them has changed.

Watches each item in the collection and notifies when any of them has changed.

Watches each item in the collection and notifies when any of them has changed.

Includes changes for the specified reasons only.

Excludes updates for the specified reasons.

Apply a logical Xor operator between the collections. Items which are only in one of the sources are included in the result.

Apply a logical Xor operator between the collections. Items which are only in one of the sources are included in the result.

Dynamically apply a logical Xor operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Dynamically apply a logical Xor operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Dynamically apply a logical Xor operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

This is a thing I lifted from Prism.