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