Snippets tagged observable
-
Observable.Subject
The Subject
29 people like thistype implements both IObserver and IObservable . It is functionally equivalent to the type of the same name in the Reactive Extensions (Rx) library.
Like the snippet!Posted: 13 years ago by Phillip Trelford
-
Creating observable using Async.StartDisposable
Implements a simple Async.StartDisposable extension that can be used to easily create IObservable values from F# asynchronous workflows. The method starts an asynchronous workflow and returns IDisposable that cancels the workflow when disposed.
4 people like this
Like the snippet!Posted: 13 years ago by Tomas Petricek
-
Observable Async Subject
Simple Async Observable Subject<'T> based on MailboxProcessor. Type declaration is more ML like, but the idea is represented in a simple way!
6 people like this
Like the snippet!Posted: 12 years ago by Fahad
-
Rx vs Observable module vs Nessos Streams
Naive performance comparison of push model libraries: Reactive Extension (Rx), Observable module (built-in to F#) and Nessos Streams. Note: smaller numbers are better
12 people like this
Like the snippet!Posted: 10 years ago by Phillip Trelford
-
Observable Agent
Extension to Control.Observable module to create an Observable linked to a MailboxProcessor. Messages posted to the mailbox are published to subscribers. Requires a cancelation token which when cancelled sends OnComplete to subscribers. Only the Post method is exposed from the internally created MailboxProcessor.
2 people like this
Like the snippet!Posted: 7 years ago by Faisal Waris
-
ReplaySubject
The ReplaySubject
3 people like thistype implements both IObserver and IObservable . It is functionally equivalent to the class of the same name in the Reactive Extensions (Rx) library with a replay buffer of a specified size .
Like the snippet!Posted: 13 years ago by Phillip Trelford
-
Sliding window for Observable
Implements the Observable.windowed function that creates an observable returning a sliding window. The function is an observable version of Seq.observable. The implementation uses a simple F# agent that keeps partial windows and sends them to an observer.
6 people like this
Like the snippet!Posted: 13 years ago by Tomas Petricek
-
AsyncBuilder extension for maniplating other containers by using keyword
AsyncBuilder extension for maniplating some other containers directory in asynchronous workflow. Bind methods in the extension enables you to retrieve inner values of 'a IObservable and 'a IEvent by using let! or do! keyword without Async.AwaitEvent or AsyncAwaitObservable. For method in the extension omits let! binding. Yield method in the extension enables you to yield value in for expression in asynchronous workflow.
3 people like this
Like the snippet!Posted: 11 years ago by nagat01
-
Floating window over observables
Creates an observable that returns windows of size 'n' (or smaller at the start) containing 'n' past values produced by observable 'source'. The order of items in the returned buffers is not guaranteed (it's a circular buffer).
3 people like this
Like the snippet!Posted: 8 years ago by Tomas Petricek