package lambda_streams_async

  1. Overview
  2. Docs
Async helpers for lambda_streams

Install

Dune Dependency

Authors

Maintainers

Sources

0.1.2.tar.gz
md5=8c1ce04ee769b56434696bd57aee1a5b
sha512=9bb794f3852da60e536277f41ca5c6db678e5f0f5100ca13bf4c054a8d5c17834891c9ba2d73ddd35dc4f52f4b8be6076611b8f8c413eb6e93d61c161c67f9aa

Description

Published: 21 Mar 2020

README

lambda-streams

A lambda-based streaming library. Read the introduction here.

Installation

For native ocaml:

opam install lambda-streams

For bucklescript:

yarn add lambda-streams

Documentation

See documentation

Examples

There are several kinds of streams. The simplest is a Finite.Sync stream:

# #require "lambda_streams";;
# open Lambda_streams;;
# let foo = Finite.Sync.from_list [1; 2; 3];;
val foo : int Finite.Sync.input = <fun>
# let bar = foo |> Finite.Sync.map (( * ) 2) |> Finite.Sync.to_list;;
val bar : int list = [2; 4; 6]

License

See LICENSE

Dependencies (7)

  1. dune >= "2.2.0"
  2. core >= "v0.12.0"
  3. async_unix >= "v0.12.0"
  4. async_kernel >= "v0.12.0"
  5. async >= "v0.12.0"
  6. lambda_streams = version
  7. ocaml >= "4.07"

Dev Dependencies (2)

  1. alcotest-async >= "1.0.1" & with-test
  2. alcotest >= "1.0.1" & with-test

Used by

None

Conflicts

None

OCaml

Innovation. Community. Security.