LanguageExt.Pipes

LanguageExt.Pipes ► Concurrent

Contents

Sub modules

Inbox
Mailbox
Outbox

record Buffer <A> Source #

Settings for Mailbox channels

Parameters

type A

Bound value type

Fields

field Buffer<A> Unbounded = new UnboundedBuffer<A>() Source #

Store an unbounded number of messages in a FIFO queue

field Buffer<A> Single = new SingleBuffer<A>() Source #

Bounded number of messages to 1

field Buffer<A> New = new NewBuffer<A>() Source #

Newest(1)

Methods

method Buffer<A> Bounded (uint size) Source #

Store a bounded number of messages, specified by the 'size' argument

Parameters

param size

Bounded size of the buffer

method Buffer<A> Latest (A value) Source #

Only store the 'Latest' message, beginning with an initial value

'Latest' is never empty nor full.

method Buffer<A> Newest (uint size) Source #

Like Bounded, but Post never fails (the buffer is never full). Instead, old elements are discarded to make room for new elements

Parameters

param size

Size of the buffer

record UnboundedBuffer <A> Source #

record BoundedBuffer <A> (uint Size) Source #

record SingleBuffer <A> Source #

record LatestBuffer <A> (A Value) Source #

record NewestBuffer <A> (uint Size) Source #

record NewBuffer <A> Source #