src/Service/EsSocket.php line 13

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use SocketIO\Emitter;
  6. use Symfony\Component\Cache\Adapter\RedisAdapter;
  8. class EsSocket
  9. {
  10.     private $redisClient;
  11.     private $socketEmitter;
  13.     public function __construct($redisDsn)
  14.     {
  15.         $this->redisClient = RedisAdapter::createConnection($redisDsn);
  16.         $this->socketEmitter = new Emitter($this->redisClient);
  17.     }
  19.     public function emit($event, $payload = [])
  20.     {
  21.         $this->socketEmitter->emit($event, $payload);
  22.     }
  23. }