module

Echo::Producer(Message, Stream)

A Producer application creates and sends messages to a Stream. Consumer applications create a subscription to a event to receive messages from it. Communication can be one-to-many (fan-out), many-to-one (fan-in), and many-to-many.

Instance methods

publish(message : Message)

Publishes a message of type M

Source

publish(*args)

Publishes a message of type M constructed from a tuple arguments

Source

publish

Publishes a message of type M constructed from named tuple arguments

Source