Sha256: d09b1285a2214856d919bf0b6bdd026e6339640cfee592b6a5bec3f71818d191
Contents?: true
Size: 838 Bytes
Versions: 22
Compression:
Stored size: 838 Bytes
Contents
module AnyCable
module BroadcastAdapters
class Http < Base
RECOVERABLE_EXCEPTIONS: Array[singleton(Class)]
OPEN_TIMEOUT: Integer
READ_TIMEOUT: Integer
MAX_ATTEMPTS: Integer
DELAY: Integer
attr_reader url: String
attr_reader headers: Hash[String, String]
attr_reader authorized: bool
alias authorized? authorized
def initialize: (?url: String url, ?secret: String secret) -> void
def shutdown: () -> void
private
attr_reader uri: URI::Generic
attr_reader queue: Thread::Queue
attr_reader thread: Thread?
def ensure_thread_is_alive: () -> void
def perform_request: (String payload) -> untyped
def handle_response: (untyped response) -> void
def build_http: () { (untyped) -> untyped } -> untyped
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems