FSharpx.Async


ObservableExtensions

Namespace: FSharpx.Control

Static members

Static memberDescription
BufferWithTimeOrCount(...)
Signature: (source:IObservable<'TSource> * timeSpan:TimeSpan * count:int) -> IObservable<seq<'TSource>>
Type parameters: 'TSource
CombineLatest(left, right, selector)
Signature: (left:IObservable<'TLeft> * right:IObservable<'TRight> * selector:Func<'TLeft,'TRight,'TResult>) -> IObservable<'TResult>
Type parameters: 'TLeft, 'TRight, 'TResult
Delay(source, milliseconds)
Signature: (source:IObservable<'TSource> * milliseconds:int) -> IObservable<'TSource>
Type parameters: 'TSource
Merge(source, sources)
Signature: (source:IObservable<'TSource> * sources:IObservable<'TSource> []) -> IObservable<'TSource>
Type parameters: 'TSource
Merge(source, sources)
Signature: (source:IObservable<'TSource> * sources:IEnumerable<IObservable<'TSource>>) -> IObservable<'TSource>
Type parameters: 'TSource
Scan(source, seed, f)
Signature: (source:IObservable<'TSource> * seed:'TAccumulate * f:Func<'TAccumulate,'TSource,'TAccumulate>) -> IObservable<'TAccumulate>
Type parameters: 'TSource, 'TAccumulate
Select(source, selector)
Signature: (source:IObservable<'TSource> * selector:Func<'TSource,int,'TResult>) -> IObservable<'TResult>
Type parameters: 'TSource, 'TResult
Select(source, selector)
Signature: (source:IObservable<'TSource> * selector:Func<'TSource,'TResult>) -> IObservable<'TResult>
Type parameters: 'TSource, 'TResult
SelectMany(...)
Signature: (source:IObservable<'TSource> * collectionSelector:Func<'TSource,IEnumerable<'TCollection>> * resultSelector:Func<'TSource,'TCollection,'TResult>) -> IObservable<'TResult>
Type parameters: 'TSource, 'TCollection, 'TResult
Subscribe(source, action)
Signature: (source:IObservable<'TSource> * action:Action<'TSource>) -> IDisposable
Type parameters: 'TSource
TakeWhile(source, f)
Signature: (source:IObservable<'TSource> * f:Func<'TSource,bool>) -> IObservable<'TSource>
Type parameters: 'TSource
Throttle(source, dueTime)
Signature: (source:IObservable<'TSource> * dueTime:TimeSpan) -> IObservable<'TSource>
Type parameters: 'TSource
ToObservable(source)
Signature: source:IEnumerable<'TItem> -> IObservable<'TItem>
Type parameters: 'TItem
Where(source, predicate)
Signature: (source:IObservable<'TSource> * predicate:Func<'TSource,bool>) -> IObservable<'TSource>
Type parameters: 'TSource
Zip(left, right, selector)
Signature: (left:IObservable<'TLeft> * right:IObservable<'TRight> * selector:Func<'TLeft,'TRight,'TResult>) -> IObservable<'TResult>
Type parameters: 'TLeft, 'TRight, 'TResult
Fork me on GitHub