PlaceOS::Driver::TransportWebsocket
Inherits PlaceOS::Driver::Transport < Reference < Object
Constructors
new(queue : PlaceOS::Driver::Queue, uri : String, settings : PlaceOS::Driver::Settings, headers_callback : -> HTTP::Headers, &received : Bytes, PlaceOS::Driver::Task | Nil -> Nil)
timeouts in seconds
Instance methods
connect(connect_timeout : Int32 = 10) : Nil
Sourcedisconnect
Sourceenable_multicast_loop(state = true)
http(method, path, body : HTTP::Client::BodyType = nil, params : Hash(String, String | Nil) | URI::Params = URI::Params.new, headers : Hash(String, String) | HTTP::Headers = HTTP::Headers.new, secure = false, concurrent = true) : HTTP::Client::Response
ping(message = nil)
Sourcepong(message = nil)
Sourcereceived
Sourcesend(message) : PlaceOS::Driver::TransportWebsocket
Sourcesend(message, task : PlaceOS::Driver::Task, &block : Bytes, PlaceOS::Driver::Task -> Nil) : PlaceOS::Driver::TransportWebsocket
Sourceterminate
Source