package lwt-parallel

  1. Overview
  2. Docs

Module Parallel.IoSource

Serialization Protocols.

Sourceval define : put:(Lwt_io.output_channel -> 'a -> unit Lwt.t) -> get:(Lwt_io.input_channel -> 'a Lwt.t) -> 'a io

define ~put ~get defines a new serialization protocol.

The put function is responsible for writing the messages to the channel. The get function is responsible for reading the messages from the channel.

Sourceval put : 'a io -> Lwt_io.output_channel -> 'a -> unit Lwt.t

put io chan x uses protocol io to write x to chan.

Sourceval get : 'a io -> Lwt_io.input_channel -> 'a Lwt.t

get io chan uses protocol io to read a message from chan.

Sourceval marshaling : 'a io

marshalling io uses the Marshal module to serialize messages.