LanguageExt.Pipes

LanguageExt.Pipes ► Concurrent

Contents

Sub modules

Conduit
Sink
Source

record Buffer <A> Source #

Settings for Conduit channels

Parameters

type A

Bound value type

Fields

field Buffer<A> Unbounded Source #

Store an unbounded number of messages in a FIFO queue

field Buffer<A> Single Source #

Bounded number of messages to 1

field Buffer<A> New 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 #