package fiber

You can search for identifiers within the package.

in-package search v0.2.0

fiber
- CHANGES
- LICENSE
- README
- Library fiber
  - Fiber
    
    O
    
    Make_map_traversals
    
    Var
    
    Ivar
    
    Mvar
    
    Svar
    
    Mutex
    
    Throttle
    
    Stream
    
    In
    
    Out
    
    Pool
    
    Scheduler
    
    Expert
- Sources
  - fiber
    
    fiber.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Fiber.Stream`Source

Destructive streams that can be composed to pipelines.

Streams can be finite or infinite. Streams have no storage and can only have one writer and/or one reader at any given time. If you'd like to access a stream concurrently, you need to protect it via a mutex.

Trying to access the same side of a stream concurrently will result in an error.

Sourcemodule In : sig ... end

Sourcemodule Out : sig ... end

Sourceval connect : 'a In.t -> 'a Out.t -> unit fiber

connect i o reads from i and writes to o. Closes o when i is exhausted. Returned fiber terminates when i is exhausted

Sourceval supply : 'a In.t -> 'a Out.t -> unit fiber

supply i o like connect i o but does not close o once i is exhausted, allowing more values to be pused to o. Returned fiber terminates when i is exhausted

Sourceval pipe : unit -> 'a In.t * 'a Out.t

pipe () returns (i, o) where values pushed through o can be read through i.

package fiber

Module Fiber.StreamSource

Module `Fiber.Stream`Source