package mirage-flow-lwt
Various implementations of the MirageOS FLOW interface
Install
Dune Dependency
Authors
Maintainers
Sources
mirage-flow-lwt-1.2.0.tbz
sha256=6e3c0879fc42dca63746319dcdace471a43789734843259178da757d3f5fa393
md5=18b4752fbb9922b57cd25738557b7ef4
Description
Fflow
uses input/output functions to build a flowLwt_io_flow
usesLwt_io.channel
README
mirag-flow -- Flow implementations and combinators for MirageOS
This repo contains generic operations over Mirage FLOW
implementations.
Please consult the API documentation.
Example usage
In a top-level like utop:
# #require "mirage-flow";;
# #require "mirage-clock-unix";;
# #require "lwt.syntax";;
# let a = Mirage_flow.Fun.(make ~input:(input_string "hellooooo") ());;
val a : Mirage_flow.Fun.flow = <abstr>
# let buffer = String.make 20 ' ';;
val buffer : bytes = " "
# let b = Mirage_flow.Fun.(make ~output:(output_string buffer) ());;
val b : Mirage_flow.Fun.flow = <abstr>
# lwt results = Mirage_flow.copy (module Clock) (module Mirage_flow.Fun) a (module Mirage_flow.Fun) b ();;
val results : [ `Error of [ `Msg of bytes ] | `Ok of Mirage_flow.CopyStats.t ] = `Ok {Mirage_flow.CopyStats.read_bytes = 9L; read_ops = 1L; write_bytes = 9L; write_ops = 1L; duration = 6.9141387939453125e-06}
# buffer;;
- : bytes = "hellooooo "
Dependencies (10)
-
mirage-flow
= "1.2.0"
-
mirage-clock
= "1.2.0"
- cstruct-lwt
-
cstruct
>= "2.0.0" & < "6.0.1"
- lwt
-
fmt
< "0.8.10"
-
topkg
build & >= "0.7.3"
-
ocamlbuild
build
-
ocamlfind
build
- ocaml
Dev Dependencies
None
Used by (22)
-
capnp-rpc-lwt
< "0.5.0"
-
capnp-rpc-net
< "0.6.0"
-
cohttp-mirage
< "2.4.0"
-
conduit-mirage
< "2.0.2"
-
datakit-client-git
>= "1.0.0"
-
datakit-server
>= "0.10.0" & < "0.11.0"
- datakit-server-9p
-
dns-forward
>= "0.9.0"
-
git-mirage
< "2.1.2"
-
hvsock
>= "0.14.0" & < "3.0.0"
- mirage-channel-lwt
-
mirage-conduit
< "2.0.0" | >= "2.3.0"
- mirage-flow-rawlink
-
mirage-flow-unix
!= "1.3.0" & < "2.0.0"
-
mirage-http
>= "3.0.0"
- mirage-net-flow
-
mirage-types-lwt
>= "3.0.0" & < "3.4.0"
-
protocol-9p
>= "0.9.0" & < "2.0.2"
-
protocol-9p-unix
< "2.0.2"
-
vchan
>= "2.3.0" & < "5.0.0"
-
vchan-unix
< "5.0.0"
-
vchan-xen
< "5.0.0"
Conflicts
None
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>
On This Page