class

Crystalforce::StreamingClient

Inherits Reference / Object

Constructors

new(instance_url : String, access_token : String, api_version : String | Nil = nil)
Source

Instance methods

disconnect
Source
subscribe(channels : Array(String), replay : Hash(String, Int64) | Nil = nil, &block : JSON::Any -> )

Subscribe to channels and yield messages

Source
subscribe(channel : String, replay_id : Int64 = -1, &block : JSON::Any -> )

Subscribe to a single channel

Source