spoke/tcp

Values

connector

pub fn connector(
  host host: String,
  port port: Int,
  connect_timeout connect_timeout: Int,
) -> fn() -> Result(mqtt_actor.TransportChannel, String)

Constructs an (unencrypted) TCP connector.

connector_with_defaults

</>

pub fn connector_with_defaults(
  host host: String,
) -> fn() -> Result(mqtt_actor.TransportChannel, String)

Constructs an (unencrypted) TCP connector using the defaults of connecting to port 1883 on the given host.