LanguageExt.Streaming

LanguageExt.Streaming Event

Contents

class Event <A> Source #

Adds itself to the Action event-delegate and then forwards anything posted by the event to any subscribers to this type. We're trying to make events a bit more 'first class, rather than the 'runt of the litter' that they are now.

So, as long as you can find a way to make your event into a single argument action, you can then use it with the streaming functionality within this library.

Parameters

type A

Value type

Constructors

constructor Event (ref Action<A> @delegate) Source #

Construct an event from subscribing to the delegate

Parameters

param delegate

The delegate that this type will subscribe to

Methods

method IO<Source<A>> Subscribe () Source #

Subscribe to this event

method SourceT<M, A> Subscribe <M> () Source #

where M : MonadIO<M>, Fallible<M>

Subscribe to this event

method IO<Unit> Unsubscribe (Subscription sub) Source #

method IO<Unit> UnsubscribeAll () Source #

method void Dispose () Source #

class Subscription Source #

Methods

method void Dispose () Source #

class Event Source #

Methods

method Event<A> from <A> (ref Action<A> eventDelegate) Source #

Create an Event from an event delegate

Parameters

type A

Value type

param eventDelegate

Delegate to which the event will listen for values

returns

Event that can be passed around in a first-class manner