package lambda_streams_async

You can search for identifiers within the package.

in-package search v0.2.0

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

Module `Lambda_streams_async.Async`Source

val first_to_async : 
  'a Lambda_streams.Finite.Async.t ->
  'a Async_kernel.Deferred.t

Gets the first value of a lambda stream and turns it into a deferred value

val last_to_async : 
  'a Lambda_streams.Finite.Async.t ->
  'a Async_kernel.Deferred.t

Gets the last value of a lambda stream and turns it into a deferred value

val to_async_list : 
  'a Lambda_streams.Finite.Async.t ->
  'a list Async_kernel.Deferred.t

Sourceval from_async : 'a Async_kernel.Deferred.t -> 'a Lambda_streams.Finite.Async.t

val to_async_stream : 
  'a Lambda_streams.Finite.Async.t ->
  'a Async_kernel.Stream.t

val from_async_stream : 
  'a Async_kernel.Stream.t ->
  'a Lambda_streams.Finite.Async.t

val to_reader : 
  'a Lambda_streams.Finite.Async.t ->
  'a Async_kernel.Pipe.Reader.t

val from_reader : 
  'a Async_kernel.Pipe.Reader.t ->
  'a Lambda_streams.Finite.Async.t