Phoenix::Socket

Log = ::Log.for("phoenix")

new(endpoint : String, params : Hash(String, String) | Proc(Hash(String, String)) = {} of String => String, heartbeat_interval : Time::Span = 30.seconds, reconnect_after : Proc(Int32, Time::Span) = Timer::DEFAULT_BACKOFF, timeout : Time::Span = 10.seconds, serializer : Serializer = Serializer::JSON.new, logger : ::Log | Nil = nil)

channel(topic : String, params : JSON::Any = JSON::Any.new({} of String => JSON::Any)) : Channel

channel(topic : String, params : Hash) : Channel

disconnect(code : UInt16 | Nil = nil, reason : String | Nil = nil) : Nil

off(ref : Int32) : Nil

push(msg : Message) : Nil

remove_channel(channel : Channel) : Nil