Nats v0.1.6 Nats.Client View Source

Link to this section Summary

Functions

flush(self, timeout \\ :infinity)

pub(self, subject, what)

pub(self, subject, reply, what)

start(opts \\ %{})

start(name, opts)

start_link(opts \\ %{})

start_link(name, opts)

stop(self, timeout \\ :infinity)

sub(self, who, subject, queue \\ nil)

unsub(self, ref, afterReceiving \\ nil)

Link to this section Functions

Link to this function flush(self, timeout \\ :infinity) View Source

Link to this function pub(self, subject, what) View Source

Link to this function pub(self, subject, reply, what) View Source

Link to this function start(opts \\ %{}) View Source

Link to this function start(name, opts) View Source

Link to this function start_link(opts \\ %{}) View Source

Link to this function start_link(name, opts) View Source

Link to this function stop(self, timeout \\ :infinity) View Source

Link to this function sub(self, who, subject, queue \\ nil) View Source

Link to this function unsub(self, ref, afterReceiving \\ nil) View Source