class Steep::Server::Master::ResultController

def <<(handler)
  @handlers << handler
end

def initialize()
  @handlers = []
end

def process_response(message)
  handlers.each do |handler|
    return true if handler.process_response(message)
  end
  false
ensure
  handlers.reject!(&:completed?)
end

def request_group()
  group = GroupHandler.new()
  yield group
  group
end