package picos_std

  1. Overview
  2. Docs
Sample libraries for Picos

Install 

dune-project
 Dependency

github.com Readme Changelog ISC License Edit opam file Versions (2)

Authors

  1. V
    Vesa Karvonen <vesa.a.j.k@gmail.com>

Maintainers

  1. V
    Vesa Karvonen <vesa.a.j.k@gmail.com>

Sources

picos-0.6.0.tbz
sha256=3f5a08199cf65c2dae2f7d68f3877178f1da8eabf5376e15114e5a8958087dfa
sha512=ad24910c47ce614268c4268874bb918da7f8b5f03b3ad706bbf30323635262e94ddab6be24eaebbca706bfa82c0a517d4272b396459e020c185942125c9bdb7b

doc/picos_std.sync/Picos_std_sync/Stream/index.html

Module Picos_std_sync.StreamSource

A lock-free, poisonable, many-to-many, stream.

Readers can tap into a stream to get a cursor for reading all the values pushed to the stream starting from the cursor position. Conversely, values pushed to a stream are lost unless a reader has a cursor to the position in the stream.

Sourcetype !'a t

Represents a stream of values of type 'a.

Sourceval create : ?padded:bool -> unit -> 'a t

create () returns a new stream.

Sourceval push : 'a t -> 'a -> unit

push stream value adds the value to the current position of the stream and advances the stream to the next position unless the stream has been poisoned in which case only the exception given to poison will be raised.

Sourceval poison_at : 'a t -> exn -> Printexc.raw_backtrace -> unit

poison_at stream exn bt marks the stream as poisoned at the current position, which means that subsequent attempts to push to the stream will raise the given exception with backtrace.

ℹ️ This operation is not cancelable.

Sourceval poison : ?callstack:int -> 'a t -> exn -> unit

poison stream exn is equivalent to poison_at stream exn (Printexc.get_callstack n) where n defaults to 0.

Sourcetype !'a cursor

Represents a (past or current) position in a stream.

Sourceval tap : 'a t -> 'a cursor

tap stream returns a cursor to the current position of the stream.

Sourceval peek_opt : 'a cursor -> ('a * 'a cursor) option

peek_opt cursor immediately returns Some (value, next) with the value pushed to the position and a cursor to the next position, when the cursor points to a past position in the stream. Otherwise returns None or raises the exception that the stream was poisoned with.

Sourceval read : 'a cursor -> 'a * 'a cursor

read cursor immediately returns (value, next) with the value pushed to the position and a cursor to the next position, when the cursor points to a past position in the stream. If the cursor points to the current position of the stream, read cursor waits until a value is pushed to the stream or the stream is poisoned, in which case the exception that the stream was poisoned with will be raised.

Sourceval read_evt : 'a cursor -> ('a * 'a cursor) Picos_std_event.Event.t

read_evt cursor returns an event that reads from the cursor position.