One Hat Cyber Team

Your IP: 216.73.216.45
Server IP: 185.238.29.86
Server: Linux server2 6.8.12-6-pve #1 SMP PREEMPT_DYNAMIC PMX 6.8.12-6 (2024-12-19T19:05Z) x86_64
Server Software: nginx/1.18.0
PHP Version: 8.1.31
Buat File | Buat Folder
Dir : ~/var/www/shopware/vendor/enqueue/enqueue/Rpc/
View File Name : Promise.php

<?php

namespace Enqueue\Rpc;

use Interop\Queue\Message as InteropMessage;

class Promise
{
    /**
     * @var \Closure
     */
    private $receiveCallback;

    /**
     * @var \Closure
     */
    private $receiveNoWaitCallback;

    /**
     * @var \Closure
     */
    private $finallyCallback;

    /**
     * @var bool
     */
    private $deleteReplyQueue;

    /**
     * @var InteropMessage
     */
    private $message;

    /**
     * @param \Closure $receiveCallback
     * @param \Closure $receiveNoWaitCallback
     * @param \Closure $finallyCallback
     */
    public function __construct(\Closure $receiveCallback, \Closure $receiveNoWaitCallback, \Closure $finallyCallback)
    {
        $this->receiveCallback = $receiveCallback;
        $this->receiveNoWaitCallback = $receiveNoWaitCallback;
        $this->finallyCallback = $finallyCallback;

        $this->deleteReplyQueue = true;
    }

    /**
     * Blocks until message received or timeout expired.
     *
     * @param int $timeout
     *
     * @throws TimeoutException if the wait timeout is reached
     *
     * @return InteropMessage
     */
    public function receive($timeout = null)
    {
        if (null == $this->message) {
            try {
                if ($message = $this->doReceive($this->receiveCallback, $this, $timeout)) {
                    $this->message = $message;
                }
            } finally {
                call_user_func($this->finallyCallback, $this);
            }
        }

        return $this->message;
    }

    /**
     * Non blocking function. Returns message or null.
     *
     * @return InteropMessage|null
     */
    public function receiveNoWait()
    {
        if (null == $this->message) {
            if ($message = $this->doReceive($this->receiveNoWaitCallback, $this)) {
                $this->message = $message;

                call_user_func($this->finallyCallback, $this);
            }
        }

        return $this->message;
    }

    /**
     * On TRUE deletes reply queue after getMessage call.
     *
     * @param bool $delete
     */
    public function setDeleteReplyQueue($delete)
    {
        $this->deleteReplyQueue = (bool) $delete;
    }

    /**
     * @return bool
     */
    public function isDeleteReplyQueue()
    {
        return $this->deleteReplyQueue;
    }

    /**
     * @param \Closure $cb
     * @param array    $args
     *
     * @return InteropMessage
     */
    private function doReceive(\Closure $cb, ...$args)
    {
        $message = call_user_func_array($cb, $args);

        if (null !== $message && false == $message instanceof InteropMessage) {
            throw new \RuntimeException(sprintf(
                'Expected "%s" but got: "%s"', InteropMessage::class, is_object($message) ? get_class($message) : gettype($message)));
        }

        return $message;
    }
}