public function processClientEvent($event, array $message, ConnectionInterface $connection, WriteStream $write)
    {
        $converter = $this->getConverter();
        $converted = $converter->convert($message);
        $converted->setConnection($connection);

        $client = $this->getClient();
        $queue = $this->getEventQueueFactory()->getEventQueue($connection);
        $params = [ $converted, $queue ];
        $subtype = $this->getEventSubtype($converted);
        $client->emit($event . '.each', $params);
        $client->emit($event . '.' . $subtype, $params);

        $this->processOutgoingEvents($connection, $write);
    }