class Pakyow::TestHelp::Realtime::ObservableContext

Public Class Methods

new(context) click to toggle source
# File pakyow-test/lib/pakyow/test_help/observables/realtime/observable_context.rb, line 5
def initialize(context)
  @context = Pakyow::Realtime::Context.new(context)
  @pushes = {}
end

Public Instance Methods

method_missing(method, *args, &block) click to toggle source
# File pakyow-test/lib/pakyow/test_help/observables/realtime/observable_context.rb, line 10
def method_missing(method, *args, &block)
  @context.send(method, *args, &block)
end
push(msg, *channels) click to toggle source
# File pakyow-test/lib/pakyow/test_help/observables/realtime/observable_context.rb, line 14
def push(msg, *channels)
  channels.each do |channel|
    (@pushes[channel.to_sym] ||= []) << msg
  end
end
pushed?(message = nil, to: nil) click to toggle source
# File pakyow-test/lib/pakyow/test_help/observables/realtime/observable_context.rb, line 20
def pushed?(message = nil, to: nil)
  if to.nil? && message.nil?
    !@pushes.empty?
  elsif to.nil? && message
    @pushes.values.flatten.include?(message)
  elsif message.nil? && to
    @pushes.key?(to.to_sym)
  else
    @pushes.fetch(to.to_sym).include?(message)
  end
end