package gemini

  1. Overview
  2. Docs
package gemini
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module Inf_pipe.TSource

Sourcemodule Reader : sig ... end
Sourceval read : ?consumer:??? -> 'a Async.Pipe.Reader.t -> 'a Async_kernel__Deferred.t
Sourceval read_now : ?consumer:??? -> 'a Async.Pipe.Reader.t -> [> `Nothing_available | `Ok of 'a ]
Sourceval read_exactly : ?consumer:??? -> 'a Async.Pipe.Reader.t -> num_values:int -> 'a Core.Queue.t Async_kernel__Deferred.t
Sourceval to_pipe : 'a Async.Pipe.Reader.t -> 'a Async.Pipe.Reader.t
Sourceval interleave : 'a Async.Pipe.Reader.t list -> 'a Reader.t
Sourceval unfold : init:'s -> f:('s -> ('a * 's) Async_kernel__Deferred.t) -> 'a Reader.t
Sourceval map : 'a Async.Pipe.Reader.t -> f:('a -> 'b) -> 'b Async.Pipe.Reader.t
Sourceval filter_map : ?max_queue_length:??? -> 'a Async.Pipe.Reader.t -> f:('a -> 'b option) -> 'b Async.Pipe.Reader.t