Group of direct writers. Groups are optimized for sending the same message to multiple clients at once.
module Buffer : sig ... endA group internally holds a buffer to serialize messages only once. This buffer will grow automatically to accomodate bigger messages.
val flushed_or_closed : _ t -> unit Async_kernel.Deferred.tflushed_or_closed t is determined when the underlying writer for each member of t is flushed or closed.
val flushed : _ t -> unit Async_kernel.Deferred.tAdd a direct stream writer to the group. Raises if the writer is closed or already part of the group, or if its bin-prot writer is different than an existing group member's. When the writer is closed, it is automatically removed from the group.
Remove a writer from a group. Note that writers are automatically removed from all groups when they are closed, so you only need to call this if you want to remove a writer without closing it.
val write : 'a t -> 'a -> unit Async_kernel.Deferred.tWrite a message on all direct writers in the group. Contrary to Direct_stream_writer.write, this cannot return `Closed as elements of the group are removed immediately when they are closed.
write t x is the same as write_without_pushback t x; flushed t.
Note: if the group was created with ~send_last_value_on_add:true, all write functions will save the value when written. If there are writers in the group at the time of writing, it will be serialized and saved to the buffer, but if there are no writers it will hold onto the 'a. This means that it is unsafe to use if the 'a is mutable or if it has a finalizer that is expected to be run
val write_without_pushback : 'a t -> 'a -> unitval length : _ t -> intmodule Expert : sig ... endWhen these functions are used with a group created with ~send_last_value_on_add:true, the group will save a copy of the relevant part of the buffer in order to send it to writers added in the future.