Bytesrw extends the OCaml Bytes
module with composable, memory efficient, byte stream readers and writers compatible with effect based concurrency.
Except for byte slice life-times, these abstractions intentionally separate away ressource management and the specifics of reading and writing bytes.
The following manuals are available:
bytesrw
This library has the base definition of byte stream reader and writers as an extension of the Stdlib.Bytes
module.
Bytesrw
Extended Stdlib.Bytes
module. Open to use it.Bytesrw.Bytes.Slice
Byte slices.Bytesrw.Bytes.Stream
Byte streams.Bytesrw.Bytes.Reader
Byte stream readers.Bytesrw.Bytes.Writer
Byte stream writers.The following modules rely only on the Stdlib
:
Bytesrw_utf
UTF streams.Bytesrw_hex
Hexadecimal tools.bytesrw.{blake3,md,unix,xxhash,zlib,zstd}
Each of these modules lives in its corresponding library. Compression and hashing libraries depend on their canonical C library.
Bytesrw_blake3
BLAKE3
hashes.Bytesrw_md
SHA-1
and SHA-2
hashes.Bytesrw_unix
Unix
file descriptor byte stream readers and writers.Bytesrw_xxhash
XXH3-64
and XXH3-128
hashes.Bytesrw_zlib
deflate
, zlib
and gzip
streams.Bytesrw_zstd
zstd
streams.This example compresses standard input to standard output with zstd
using either a compressing byte stream reader (pull) or a compressing byte stream writer (push).
cat << 'EOF' > quickstart.ml
open Bytesrw
let stdio_compress_reads () =
try
let stdin = Bytes.Reader.of_in_channel In_channel.stdin in
let stdout = Bytes.Writer.of_out_channel Out_channel.stdout in
let params = Bytesrw_zstd.Cctx_params.make ~checksum:true () in
let zstdr = Bytesrw_zstd.compress_reads ~params () stdin in
Bytes.Writer.write_reader ~eod:true stdout zstdr;
Ok ()
with
| Bytes.Stream.Error e -> Bytes.Stream.error_to_result e
| Sys_error e -> Error e
let stdio_compress_writes () =
try
let stdin = Bytes.Reader.of_in_channel In_channel.stdin in
let stdout = Bytes.Writer.of_out_channel Out_channel.stdout in
let params = Bytesrw_zstd.Cctx_params.make ~checksum:true () in
let zstdw = Bytesrw_zstd.compress_writes ~params () ~eod:true stdout in
Bytes.Writer.write_reader ~eod:true zstdw stdin;
Ok ()
with
| Bytes.Stream.Error e -> Bytes.Stream.error_to_result e
| Sys_error e -> Error e
let main () =
Result.fold ~ok:(Fun.const 0) ~error:(fun e -> prerr_endline e; 1) @@
if Array.exists (String.equal "-w") Sys.argv
then stdio_compress_writes ()
else stdio_compress_reads ()
let () = if !Sys.interactive then () else exit (main ())
EOF
It can be compiled and used with:
ocamlfind ocamlopt -package bytesrw,bytesrw.zstd -linkpkg quickstart.ml
./a.out < quickstart.ml | zstd -d
The tutorial is a short conceptual overview of byte stream readers and writers. The cookbook has a few more tips and code snippets.