class Crystalforce::StreamingClient

• Crystalforce::StreamingClient
• Reference
• Object

Defined in:

crystalforce/streaming.cr

Constructors

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

Instance Method Summary

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

  Subscribe to channels and yield messages

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

  Subscribe to a single channel

Constructor Detail

Instance Method Detail