public function handleWsMessage($message)
    {
        if ($message->isBinary()) {
            $data = zlib_decode($message->getPayload());
        } else {
            $data = $message->getPayload();
        }

        $data = json_decode($data);
        $this->emit('raw', [$data, $this]);

        if (isset($data->s)) {
            $this->seq = $data->s;
        }

        $op = [
            Op::OP_DISPATCH        => 'handleDispatch',
            Op::OP_HEARTBEAT       => 'handleHeartbeat',
            Op::OP_RECONNECT       => 'handleReconnect',
            Op::OP_INVALID_SESSION => 'handleInvalidSession',
            Op::OP_HELLO           => 'handleHello',
            Op::OP_HEARTBEAT_ACK   => 'handleHeartbeatAck',
        ];

        if (isset($op[$data->op])) {
            $this->{$op[$data->op]}($data);
        }
    }
public function handleWsMessage($message)
    {
        if ($message->isBinary()) {
            $data = zlib_decode($message->getPayload());
        } else {
            $data = $message->getPayload();
        }

        $data = json_decode($data);
        $this->emit('raw', [$data, $this]);

        if (isset($data->s)) {
            $this->seq = $data->s;
        }

        $op = [
            Op::OP_DISPATCH        => 'handleDispatch',
            Op::OP_HEARTBEAT       => 'handleHeartbeat',
            Op::OP_RECONNECT       => 'handleReconnect',
            Op::OP_INVALID_SESSION => 'handleInvalidSession',
            Op::OP_HELLO           => 'handleHello',
            Op::OP_HEARTBEAT_ACK   => 'handleHeartbeatAck',
        ];

        if (isset($op[$data->op])) {
            $this->{$op[$data->op]}($data);
        }
    }
public function handleWsMessage ( $ message ) { if ( $ message -> isBinary ( ) ) { $ data = zlib_decode ( $ message -> getPayload ( ) ) ; } else { $ data = $ message -> getPayload ( ) ; } $ data = json_decode ( $ data ) ; $ this -> emit ( 'raw' , [ $ data , $ this ] ) ; if ( isset ( $ data -> s ) ) { $ this -> seq = $ data -> s ; } $ op = [ Op :: OP_DISPATCH => 'handleDispatch' , Op :: OP_HEARTBEAT => 'handleHeartbeat' , Op :: OP_RECONNECT => 'handleReconnect' , Op :: OP_INVALID_SESSION => 'handleInvalidSession' , Op :: OP_HELLO => 'handleHello' , Op :: OP_HEARTBEAT_ACK => 'handleHeartbeatAck' , ] ; if ( isset ( $ op [ $ data -> op ] ) ) { $ this -> { $ op [ $ data -> op ] } ( $ data ) ; } }
Handles WebSocket messages received by the client.

@param Message $message Message object.
Handles WebSocket messages received by the client .