Inject side effects into the stream using the specified adaptor.

Inject side effects into the stream using the specified sorted adaptor.

Removes the specified key from the cache. If the item is not contained in the cache then the operation does nothing.

Adds or updates the cache with the specified items.

Adds or updates the cache with the specified item.

Adds or updates the cache with the specified item.

Applied a logical And operator between the collections i.e items which are in all of the sources are included.

Applied a logical And operator between the collections i.e items which are in all of the sources are included.

Dynamically apply a logical And operator between the items in the outer observable list. 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 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 all of the sources are included in the result.

Converts the source to a readonly observable cache.

Converts the source to an read only observable cache.

Automatically refresh downstream operators when properties change.

Automatically refresh downstream operators when any properties change.

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

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

Batches the updates for the specified time period.

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.

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.

Binds the results to the specified observable collection using the default update algorithm.

Binds the results to the specified binding collection using the specified update algorithm.

Binds the results to the specified readonly observable collection using the default update algorithm.

Binds the results to the specified observable collection using the default update algorithm.

Binds the results to the specified binding collection using the specified update algorithm.

Binds the results to the specified readonly observable collection using the default update algorithm.

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

Cast the object to the specified type. Alas, I had to add the converter due to type inference issues.

Changes the primary key.

Changes the primary key.

Clears all items from the cache.

Clears all data.

Clears all data.

Clones the changes into the specified collection.

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 stream 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.

Loads the cache with the specified items in an optimised manner i.e. calculates the differences between the old and new items in the list and amends only the differences.

Loads the cache with the specified items in an optimised manner i.e. calculates the differences between the old and new items in the list and amends only the differences.

Signal observers to re-evaluate the all items.

Signal observers to re-evaluate the specified items.

Signal observers to re-evaluate the specified item.

Dynamically apply a logical Except operator between the collections Items from the first collection in the outer list are included unless contained in any of the other lists.

Dynamically apply a logical Except operator between the collections Items from the first collection in the outer list are included unless contained in any of the other lists.

Dynamically apply a logical Except operator between the collections Items from the first collection in the outer list are included unless contained in any of the other lists.

Dynamically apply a logical Except 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 Except operator between the items in the outer observable list. Items which are in any of the sources are included in the result.

Automatically removes items from the stream after the time specified by the timeSelector elapses. Return null if the item should never be removed.

Automatically removes items from the stream after the time specified by the timeSelector elapses. Return null if the item should never be removed.

Automatically removes items from the stream on the next poll after the time specified by the time selector elapses.

Automatically removes items from the stream on the next poll after the time specified by the time selector elapses.

Automatically removes items from the cache after the time specified by the time selector elapses.

Automatically removes items from the cache after the time specified by the time selector elapses.

Automatically removes items from the cache after the time specified by the time selector elapses.

Filters the specified source.

Creates a filtered stream which can be dynamically filtered.

Creates a filtered stream which can be dynamically filtered.

Creates a filtered stream which can be dynamically filtered.

Filters source on the specified property using the specified predicate. The filter will automatically reapply when a property changes. When there are likely to be a large number of property changes specify a throttle to improve performance.

Ensure that finally is always called. Thanks to Lee Campbell for this.

Flattens an update collection to it's individual items.

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

Provides a call back for each change.

Joins the left and right observable data sources, taking any left or right values and matching them, provided that the left or the right has a value. This is the equivalent of SQL full join.

Joins the left and right observable data sources, taking any left or right values and matching them, provided that the left or the right has a value. This is the equivalent of SQL full join.

Groups the right data source and joins the resulting group to the left data source, matching these using the specified key selector. Results are included when the left or the right has a value. This is the equivalent of SQL full join.

Groups the right data source and joins the resulting group to the left data source, matching these using the specified key selector. Results are included when the left or the right has a value. This is the equivalent of SQL full join.

Groups the source on the value returned by group selector factory.

Groups the source on the value returned by group selector factory. A group is included for each item in the resulting group source.

Groups the source on the value returned by group selector factory.

Groups the source using the property specified by the property selector. 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. Each update produces immutable grouping. 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.

Ignores updates when the update is the same reference.

Ignores the update when the condition is met. The first parameter in the ignore function is the current value and the second parameter is the previous value.

Only includes the update when the condition is met. The first parameter in the ignore function is the current value and the second parameter is the previous value.

Joins the left and right observable data sources, taking values when both left and right values are present This is the equivalent of SQL inner join.

Groups the right data source and joins the to the left and the right sources, taking values when both left and right values are present This is the equivalent of SQL inner join.

Groups the right data source and joins the resulting group to the left data source, matching these using the specified key selector. Results are included when the left and right have matching values. This is the equivalent of SQL inner join.

Groups the right data source and joins the resulting group to the left data source, matching these using the specified key selector. Results are included when the left and right have matching values. This is the equivalent of SQL inner join.

Invokes Refresh method for an object which implements IEvaluateAware.

Joins the left and right observable data sources, taking all left values and combining any matching right values.

Joins the left and right observable data sources, taking all left values and combining any matching right values.

Groups the right data source and joins the two sources matching them using the specified key selector, taking all left values and combining any matching right values. This is the equivalent of SQL left join.

Groups the right data source and joins the two sources matching them using the specified key selector, taking all left values and combining any matching right values. This is the equivalent of SQL left join.

Applies a size limiter to the number of records which can be included in the underlying cache. When the size limit is reached the oldest items are removed.

Limits the number of records in the cache to the size specified. When the size is reached the oldest items are removed from the cache.

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.

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.

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.

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.

Monitors the status of a stream.

Suppresses updates which are empty.

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.

Callback when an item has been updated eg. (current, previous)=>{}.

Apply a logical Or operator between the collections i.e items which are in any of the sources are included.

Apply a logical Or operator between the collections i.e items which are in any of the sources are included.

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.

Returns the page as specified by the pageRequests observable.

Populate a cache from an observable stream.

Populate a cache from an observable stream.

Populates a source into the specified cache.

Populates a source into the specified cache.

Populates a source into the specified cache.

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

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

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

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

Signal observers to re-evaluate the all items.

Signal observers to re-evaluate the specified items.

Signal observers to re-evaluate the specified item.

Removes the specified keys from the cache. Any keys not contained in the cache are ignored.

Removes the specified key from the cache. If the item is not contained in the cache then the operation does nothing.

Removes the specified keys from the cache. Any keys not contained in the cache are ignored.

Removes the specified items from the cache. Any items not contained in the cache are ignored.

Removes the specified key from the cache. If the item is not contained in the cache then the operation does nothing.

Removes the specified item from the cache. If the item is not contained in the cache then the operation does nothing.

Removes the key which enables all observable list features of dynamic data.

Removes the specified key from the cache. If the item is not contained in the cache then the operation does nothing.

Removes the specified keys from the cache. Any keys not contained in the cache are ignored.

Joins the left and right observable data sources, taking all right values and combining any matching left values.

Joins the left and right observable data sources, taking all right values and combining any matching left values.

Groups the right data source and joins the two sources matching them using the specified key selector, , taking all right values and combining any matching left values. This is the equivalent of SQL left join.

Groups the right data source and joins the two sources matching them using the specified key selector,, taking all right values and combining any matching left values. This is the equivalent of SQL left join.

Defer the subscription until loaded and skip initial change set.

Sorts a sequence as, using the comparer observable to determine order.

Sorts using the specified comparer. Returns the underlying ChangeSet as as per the system conventions. The resulting change set also exposes a sorted key value collection of of the underlying cached data.

Sorts a sequence as, using the comparer observable to determine order.

Sorts a sequence as, using the comparer observable to determine order.

Prepends an empty change set to the source.

Prepends an empty change set to the source.

Prepends an empty change set to the source.

Prepends an empty change set to the source.

Prepends an empty change set to the source.

Prepends an empty change set to the source.

Prepends an empty change set to the source.

The equivalent of rx StartsWith operator, but wraps the item in a change where reason is ChangeReason.Add.

The equivalent of rx StartWith operator, but wraps the item in a change where reason is ChangeReason.Add.

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

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 caches 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. 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, ordering by the comparer.

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

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.

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.

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.

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.

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.

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 collection, and subsequently observe observable collection changes.

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

Projects each update item to a new form using the specified transform function, providing an error handling action to safely handle transform errors without killing the stream.

Projects each update item to a new form using the specified transform function, providing an error handling action to safely handle transform errors without killing the stream.

Projects each update item to a new form using the specified transform function, providing an error handling action to safely handle transform errors without killing the stream.

Projects each update item to a new form using the specified transform function, providing an error handling action to safely handle transform errors without killing the stream.

Projects each update item to a new form using the specified transform function, providing an error handling action to safely handle transform errors without killing the stream.

Projects each update item to a new form using the specified transform function, providing an error handling action to safely handle transform errors without killing the stream.

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.

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

Transforms the object to a fully recursive tree, create a hierarchy based on the pivot function.

Converts moves changes to remove + add.

Produces a boolean observable indicating whether the latest resulting value from all of the specified observables matches the equality condition. The observable is re-evaluated whenever i) The cache changes or ii) The inner observable changes.

Produces a boolean observable indicating whether the latest resulting value from all of the specified observables matches the equality condition. The observable is re-evaluated whenever i) The cache changes or ii) The inner observable changes.

Produces a boolean observable indicating whether the resulting value of whether any of the specified observables matches the equality condition. The observable is re-evaluated whenever i) The cache changes. or ii) The inner observable changes.

Produces a boolean observable indicating whether the resulting value of whether any of the specified observables matches the equality condition. The observable is re-evaluated whenever i) The cache changes. or ii) The inner observable changes.

Updates the index for an object which implements IIndexAware.

Virtualises the underlying data from the specified source.

Returns an observable of any updates which match the specified key, proceeded with the initial cache state.

Watches updates for a single value matching the specified key.

Watches updates for a single value matching the specified key.

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 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.

This is a thing I lifted from Prism.