RxExtensions Class

Namespace
Shiny
Base Types
  • object
graph BT Type-->Base0["object"] Type["RxExtensions"] class Type type-node

Syntax

public static class RxExtensions

Methods

Name Value Summary
BufferWhile<T>(IObservable<T>, Func<T, bool>) IObservable<List<Timestamped<T>>>
This will buffer observable pings and timestamp them until the predicate check does not pass
static
DisposedBy<T>(T, CompositeDisposable) T
A function from ReactiveUI - useful for non-ui stuff too ;)
static
Respond<T>(IObserver<T>, T) void
A handy way for replying and completing an observer - common for single valued observables
static
Subscribe<T>(IObservable<T>, Action) IDisposable
static
Subscribe<T>(IObservable<T>, Action, Action<Exception>) IDisposable
static
Subscribe<T>(IObservable<T>, Action, Action<Exception>, Action) IDisposable
static
SubscribeAsync<T>(IObservable<T>, Func<T, Task>) IDisposable
static
SubscribeAsync<T>(IObservable<T>, Func<Task>) IDisposable
static
WhenAnyProperty<TSender, TRet>(TSender, Expression<Func<TSender, TRet>>) IObservable<TRet>
static
WhenAnyProperty<TSender>(TSender) IObservable<ItemChanged<TSender, string>>
static
WhenCollectionChanged(INotifyCollectionChanged) IObservable<NotifyCollectionChangedEventArgs>
static
WhenItemChanged<T>(ObservableCollection<T>) IObservable<ItemChanged<T, string>>
Will watch for changes in any observable item in the ObservableCollection
static
WhenItemValueChanged<T, TRet>(ObservableCollection<T>, Expression<Func<T, TRet>>) IObservable<ItemChanged<T, TRet>>
Will watch for a specific property change with any item in the ObservableCollection
static

Extension Methods

Name Value Summary
ReflectGet(string) object
Gets an objects property dynamically through reflection - will throw an exception if proper has no getter or property does not exists
ReflectSet(string, object) void
Sets an objects property dynamically through reflection - will throw an exception if proper has no setter, wrong type, or property does not exists
GitHub