Snippets tagged observable

  • Observable.Subject

    The Subject type implements both IObserver and IObservable. It is functionally equivalent to the type of the same name in the Reactive Extensions (Rx) library.

    26 people like this

    Posted: 6 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

    Posted: 5 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!

    5 people like this

    Posted: 5 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

    11 people like this

    Posted: 2 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

    Posted: 5 months ago by Faisal Waris

  • ReplaySubject

    The ReplaySubject type 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 .

    2 people like this

    Posted: 5 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.

    4 people like this

    Posted: 5 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

    Posted: 3 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

    Posted: 11 months ago by Tomas Petricek