class

PlaceOS::Driver::TransportHTTP

Inherits PlaceOS::Driver::Transport < Reference < Object

Implement transport

Constructors

new(queue : PlaceOS::Driver::Queue, uri : String, settings : PlaceOS::Driver::Settings, &received : -> Nil)

timeouts in seconds

Source

Instance methods

before_request

NOTE:: overloading base version of this

Source

connect(connect_timeout : Int32 = 10) : Nil

Source

disconnect

Source

enable_multicast_loop(state = true)

Implement transport

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 = false) : HTTP::Client::Response

ameba:disable Metrics/CyclomaticComplexity

Source

received

Source

received=(received : -> _)

Source

send(message) : TransportHTTP

Source

send(message, task : PlaceOS::Driver::Task, &_block : Bytes, PlaceOS::Driver::Task -> Nil) : TransportHTTP

Source

terminate

Source