# File actioncable/lib/action_cable/connection/test_case.rb, line 137
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 155
def advance_time(seconds)
  @timers.each { |timer| timer.advance(seconds) }
end

# File actioncable/lib/action_cable/connection/test_case.rb, line 149
  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 160
def subscribe(stream, callback, success_callback = nil)
  @streams[stream] << callback
  success_callback&.call
end

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

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