Summary

Types

codec()

proto_id()

Returns a specification to start this module under a supervisor.

Handle an inbound stream for a registered protocol.

Register a handler for a protocol id.

Perform an outbound request over a connection.

@type codec() ::
  {encode :: (binary() -> binary()),
   decode :: (binary() -> {:ok, binary(), binary()} | :more)}

@type proto_id() :: binary()

Returns a specification to start this module under a supervisor.

@spec handle_inbound(pid() | atom(), pid(), non_neg_integer(), proto_id(), binary()) ::
  :ok

Handle an inbound stream for a registered protocol.

@spec register(pid() | atom(), proto_id(), (binary(), binary() -> binary())) :: :ok

Register a handler for a protocol id.

@spec request(pid() | atom(), pid(), proto_id(), binary(), keyword()) ::
  {:ok, binary()} | {:error, term()}

Perform an outbound request over a connection.

@spec start_link(keyword()) :: GenServer.on_start()