Broadcasts on the given pubsub server with the given topic, event and payload.

The message is encoded as Combo.Socket.Broadcast.

Broadcasts on the given pubsub server with the given topic, event and payload.

Raises in case of crashes.

Broadcasts on the given pubsub server with the given from, topic, event and payload.

The message is encoded as Combo.Socket.Broadcast.

Broadcasts on the given pubsub server with the given from, topic, event and payload.

Raises in case of crashes.

Returns a specification to start this module under a supervisor.

See Supervisor.

@spec close(pid(), timeout()) :: :ok

Emulates the socket being closed.

Used by channel tests.

Hook invoked by Combo.PubSub dispatch.

@spec join(Combo.Socket.t(), module(), Combo.Socket.Message.t(), keyword()) ::
  {:ok, term(), pid()} | {:error, term()}

Joins the channel in socket with authentication payload.

Broadcasts on the given pubsub server with the given topic, event and payload.

The message is encoded as Combo.Socket.Broadcast.

Broadcasts on the given pubsub server with the given from, topic, event and payload.

The message is encoded as Combo.Socket.Broadcast.

Pushes a message with the given topic, event and payload to the given process.

Payloads are serialized before sending with the configured serializer.

Replies to a given ref to the transport process.

Payloads are serialized before sending with the configured serializer.

@spec socket(pid()) :: Combo.Socket.t()

Gets the socket from the channel.

Used by channel tests.