class Async::Container::Supervisor::Connection::Call

def finish(**response)
	# If the remote end has already closed the connection, we don't need to send a finished message:
	unless @queue.closed?
		self.push(id: @id, finished: true, **response)
		@queue.close
	end
end