class

Alumna::MemoryConnections

Inherits Alumna::Connections < Reference < Object

In-process sockets. One instance per App. Mutex for preview_mt.

Constructors

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

Snapshot watchers, then send outside the mutex so send IO cannot deadlock.

Source
unregister(id : String) : Nil
Source
unwatch(id : String, topic : String) : Nil
Source
watch(id : String, topic : String) : Nil
Source