module Cargosocket::StreamAdapters::CargobullAdapter
Public Class Methods
channels(cargoenv, path, query)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 14 def self.channels(cargoenv, path, query) r = dispatch_to(:call_no_transform, cargoenv, "CHANNELS", path, query) if r.first == 200 && r.last.is_a?(Array) && !r.last.empty? r.last.map(&:to_sym) end end
dispatch_to(m, *args)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 10 def self.dispatch_to(m, *args) Cargobull::Dispatch.send(m, *args) end
error(cargoenv, *args)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 36 def self.error(cargoenv, *args) if_value(dispatch_to(:call, cargoenv, "ERROR", *args), &Proc.new) end
if_value(value) { |last| ... }
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 5 def self.if_value(value) return if value.last.nil? yield(value.last) end
pop(cargoenv, *args)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 44 def self.pop(cargoenv, *args) if_value(dispatch_to(:call, cargoenv, "POP", *args), &Proc.new) end
push(cargoenv, *args)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 40 def self.push(cargoenv, *args) if_value(dispatch_to(:call, cargoenv, "PUSH", *args), &Proc.new) end
reference(cargoenv, path, query)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 21 def self.reference(cargoenv, path, query) r = dispatch_to(:call_no_transform, cargoenv, "REFERENCE", path, query) if r.first == 200 r.last end end
subscribe(cargoenv, *args)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 28 def self.subscribe(cargoenv, *args) if_value(dispatch_to(:call, cargoenv, "SUBSCRIBE", *args), &Proc.new) end
unsubscribe(cargoenv, *args)
click to toggle source
# File lib/cargosocket/stream_adapters/cargobull_adapter.rb, line 32 def self.unsubscribe(cargoenv, *args) if_value(dispatch_to(:call, cargoenv, "UNSUBSCRIBE", *args), &Proc.new) end