class

Phoenixchannels::Socket

Inherits Reference < Object

Constructors

new(address : String, params = Hash(String, Array(String)).new)

abnormal_close(reason : String)

channel(topic : String, payload : T) forall T

install_heartbeat(heartbeat_timeout : Time::Span = 1.second)

make_ref

run

send(msg : Message)

stream_messages(decode_type : T.class) : Channel(Message(T)) forall T

stream_messages_with_filter(once, decode_type : T.class, &filter : Message(T) -> Bool) : Channel(Message(T)) forall T