# File actioncable/lib/action_cable/connection/test_case.rb, line 139
def initialize(server)
  @streams = Hash.new { |h, k| h[k] = [] }
  @config = server.config
  @timers = []
end

# File actioncable/lib/action_cable/connection/test_case.rb, line 158
def advance_time(seconds)
  @timers.each { |timer| timer.advance(seconds) }
end

# File actioncable/lib/action_cable/connection/test_case.rb, line 152
  def post(&work) = work.call

  def timer(every, &block)
    TestTimer.new(every, &block).tap { |t| @timers << t }
  end

  def advance_time(seconds)
    @timers.each { |timer| timer.advance(seconds) }
  end

  # Pub/sub interface
  # -----------------
  def subscribe(stream, callback, success_callback = nil)
    @streams[stream] << callback
    success_callback&.call
  end

  def unsubscribe(stream, callback)
    @streams[stream].delete(callback)
    @streams.delete(stream) if @streams[stream].empty?
  end
end

# File actioncable/lib/action_cable/connection/test_case.rb, line 164
def subscribe(stream, callback, success_callback = nil)
  @streams[stream] << callback
  success_callback&.call
end

# File actioncable/lib/action_cable/connection/test_case.rb, line 154
def timer(every, &block)
  TestTimer.new(every, &block).tap { |t| @timers << t }
end

# File actioncable/lib/action_cable/connection/test_case.rb, line 169
def unsubscribe(stream, callback)
  @streams[stream].delete(callback)
  @streams.delete(stream) if @streams[stream].empty?
end