package cfstream

You can search for identifiers within the package.

in-package search v0.2.0

package cfstream

cfstream
- README
- Library cfstream
  - CFStream
    
    Stream
    
    Result
    
    Or_error
    
    Infix
    
    Streamable
    
    S
    
    S2
- Sources
  - cfstream
    
    CFStream.ml
    
    CFStream_about.ml
    
    CFStream_stream.ml
    
    CFStream_streamable.ml
    
    cFStream__.ml

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

Module `Stream.Or_error`Source

Specialisation of CFStream_stream.Result for 'a Or_error.t

Sourcetype 'a t = 'a Core_kernel.Or_error.t Stream.t

Source

val all : 
  'a t ->
  f:('a Stream.t -> 'b Core_kernel.Or_error.t) ->
  'b Core_kernel.Or_error.t

Sourceval all' : 'a t -> f:('a Stream.t -> 'b) -> 'b Core_kernel.Or_error.t

Sourceval to_exn : 'a t -> error_to_exn:(Core_kernel.Error.t -> exn) -> 'a Stream.t

Sourceval map : 'a t -> f:('a -> 'b Core_kernel.Or_error.t) -> 'b t

map' rs ~f maps Ok results with a partial function f

Sourceval map' : 'a t -> f:('a -> 'b) -> 'b t

map rs ~f maps Ok results with a total function f

Source

val map2_exn : 
  'a t ->
  'b t ->
  f:('a -> 'b -> 'c Core_kernel.Or_error.t) ->
  'c t

Generalization of map with two streams of results. If the two streams fail simultaneously, one of the two errors is propagated.

Sourceval map2_exn' : 'a t -> 'b t -> f:('a -> 'b -> 'c) -> 'c t

Analoguous of map2_exn for total functions

Source

val fold : 
  'a t ->
  init:'b ->
  f:('b -> 'a -> 'b Core_kernel.Or_error.t) ->
  'b Core_kernel.Or_error.t

fold rs ~init ~f computes a value by iterating f on each Ok element of rs starting from init. The computation stops with an Error case as soon as one is met on the stream, or when f returns one.

Sourceval fold' : 'a t -> init:'b -> f:('b -> 'a -> 'b) -> 'b Core_kernel.Or_error.t

Same as fold, but for total functions.

package cfstream

Module Stream.Or_errorSource

Module `Stream.Or_error`Source