class Async::Container::Supervisor::Connection::Call
def finish(**response)
def finish(**response) self.push(id: @id, finished: true, **response) @queue.close end
def finish(**response) self.push(id: @id, finished: true, **response) @queue.close end