class

Alumna::Connections

Inherits Reference < Object

Local connection table. Delivery is this process only. Not a NATS bus.

Instance methods

close_all
Source
register(id : String, socket : PushSocket) : Nil
Source
send(id : String, payload : String | Bytes) : Bool

True if the id is registered and send did not fail.

Source
send_topic(topic : String, payload : String | Bytes) : Nil
Source
unregister(id : String) : Nil
Source
unwatch(id : String, topic : String) : Nil
Source
watch(id : String, topic : String) : Nil
Source