Crux vdev Crux.Gateway.Connection.Producer View Source

Handles dispatching of packets received from the gateway.

Every Crux.Gateway.Connection (shard) has its own producer, defaults to GenStage.BroadcastDispatchers.

The dispatcher can be overriden via Crux.Gateway.options/0

For more informations regarding Consumers and Producers consult GenStage's documentation.

Link to this section Summary

Functions

Computes a map of all producer pid/0s keyed by shard_id

Link to this section Functions

Link to this function

producers(gateway) View Source
producers(gateway :: Crux.Gateway.gateway()) :: %{
  optional(non_neg_integer()) => pid()
}

Computes a map of all producer pid/0s keyed by shard_id.