module Echo::Producer(Message, Stream)

Overview

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.

Defined in:

echo/producer.cr

Instance Method Summary

Instance Method Detail

def publish(message : Message) #

Publishes a message of type M


[View source]
def publish(*args) #

Publishes a message of type M constructed from a tuple arguments


[View source]
def publish(**args) #

Publishes a message of type M constructed from named tuple arguments


[View source]