class Worker::ApiClient::WebsocketClient

Defined in:

worker/api_client/websocket_client.cr

Constant Summary

Log = Worker::ApiClient::Log.for("ws")
RECONNECT_INTERVAL = 30.seconds

Constructors

Instance Method Summary

Constructor Detail

def self.new(worker : Worker) #

[View source]

Instance Method Detail

def message(channel : String, data : String) #

[View source]
def on(channel : String, &block : MessageHandler) : Nil #

[View source]
def run : Nil #

[View source]
def stop : Nil #

[View source]