protected function onSuccess(array $message)
    {
        list($topic, $payload, $sequence) = $message;

        $sequence = strlen(bin2hex($sequence)) == PHP_INT_SIZE ?
            unpack('I', $sequence)[1] : 0;

        if ($this->sequence > 0 && (($this->sequence + 1) != $sequence)) {
            throw new UnexpectedValueException(
                "Broken sequence on sequence number $sequence. ".
                'Detected lost notifications.'
            );
        }

        return ($this->callback)(
            bin2hex($payload),
            $this->sequence = $sequence
        );
    }
protected function onSuccess(array $message)
    {
        list($topic, $payload, $sequence) = $message;

        $sequence = strlen(bin2hex($sequence)) == PHP_INT_SIZE ?
            unpack('I', $sequence)[1] : 0;

        if ($this->sequence > 0 && (($this->sequence + 1) != $sequence)) {
            throw new UnexpectedValueException(
                "Broken sequence on sequence number $sequence. ".
                'Detected lost notifications.'
            );
        }

        return ($this->callback)(
            bin2hex($payload),
            $this->sequence = $sequence
        );
    }
protected function onSuccess ( array $ message ) { list ( $ topic , $ payload , $ sequence ) = $ message ; $ sequence = strlen ( bin2hex ( $ sequence ) ) == PHP_INT_SIZE ? unpack ( 'I' , $ sequence ) [ 1 ] : 0 ; if ( $ this -> sequence > 0 && ( ( $ this -> sequence + 1 ) != $ sequence ) ) { throw new UnexpectedValueException ( "Broken sequence on sequence number $sequence. " . 'Detected lost notifications.' ) ; } return ( $ this -> callback ) ( bin2hex ( $ payload ) , $ this -> sequence = $ sequence ) ; }
Success callback.

@param  array  $message

@return mixed
Success callback .