package mirage-flow-combinators
Flow implementations and combinators for MirageOS specialized to lwt
Install
Dune Dependency
Authors
Maintainers
Sources
mirage-flow-4.0.0.tbz
sha256=aeacf09173fe7f42c8a3f50bb1c85206faf2583d3111b6baefef6bf0f0e4487d
sha512=f72ce1bb95c07abc02fb4fe728209dcae45144bab2a5402f8d41779ec1d810e731e5f6b503d6618ae12174c8b60370386541242263aa12092eeb159ee086cf5c
Description
This repo contains generic operations over Mirage FLOW
implementations.
Please consult the API documentation.
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 (8)
-
mirage-flow
= version
-
mirage-clock
>= "3.0.0"
-
cstruct
>= "6.0.0"
- logs
-
lwt
>= "4.0.0"
-
fmt
>= "0.8.7"
-
dune
>= "1.0"
-
ocaml
>= "4.08.0"
Dev Dependencies
None
Used by (4)
-
conduit-mirage
>= "2.0.2" & != "3.0.0"
-
hvsock
>= "3.0.0"
-
mirage-channel
>= "4.0.0"
-
mirage-flow-unix
= "4.0.0"
Conflicts
None
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>
On This Page