BatchedCommunication.Buffer (batched_communication v0.3.0)

Copy Markdown View Source

Summary

Types

dest()
proc()
t()

Functions

add(arg0, max, compression, dest, msg)
encode_messages(arg0, compression)
make(node, wait_time, dest, msg)

Types

dest()

@type dest() :: proc() | [proc()]

proc()

@type proc() :: pid() | atom()

t()

@type t() :: {pos_integer(), reference(), [{dest(), any()}]}

Functions

add(arg0, max, compression, dest, msg)

@spec add(t(), pos_integer(), BatchedCommunication.Compression.t(), dest(), any()) ::
  {:flush, BatchedCommunication.EncodedBatch.t()} | t()

encode_messages(arg0, compression)

@spec encode_messages(t(), BatchedCommunication.Compression.t()) ::
  BatchedCommunication.EncodedBatch.t()

make(node, wait_time, dest, msg)

@spec make(node(), pos_integer(), dest(), any()) :: t()