| /plugin/authgooglesheets/vendor/google/apiclient-services/src/CloudSearch/ |
| H A D | UnreserveItemsRequest.php | 31 public $queue; variable in Google\\Service\\CloudSearch\\UnreserveItemsRequest
64 public function setQueue($queue) argument
66 $this->queue = $queue;
73 return $this->queue;
|
| H A D | DeleteQueueItemsRequest.php | 31 public $queue; variable in Google\\Service\\CloudSearch\\DeleteQueueItemsRequest
64 public function setQueue($queue) argument
66 $this->queue = $queue;
73 return $this->queue;
|
| H A D | Item.php | 43 public $queue; variable in Google\\Service\\CloudSearch\\Item
140 public function setQueue($queue) argument
142 $this->queue = $queue;
149 return $this->queue;
|
| H A D | PollItemsRequest.php | 36 public $queue; variable in Google\\Service\\CloudSearch\\PollItemsRequest
87 public function setQueue($queue) argument
89 $this->queue = $queue;
96 return $this->queue;
|
| /plugin/authgooglesheets/vendor/guzzlehttp/promises/src/ |
| H A D | Utils.php | 24 public static function queue(TaskQueueInterface $assign = null) function in GuzzleHttp\\Promise\\Utils
26 static $queue;
29 $queue = $assign;
30 } elseif (!$queue) {
31 $queue = new TaskQueue();
34 return $queue;
47 $queue = self::queue();
48 $promise = new Promise([$queue, 'run']);
49 $queue->add(function () use ($task, $promise) {
|
| H A D | RejectedPromise.php | 35 $queue = Utils::queue();
37 $p = new Promise([$queue, 'run']);
38 $queue->add(static function () use ($p, $reason, $onRejected) {
|
| H A D | TaskQueue.php | 17 private $queue = []; variable in GuzzleHttp\\Promise\\TaskQueue
36 return !$this->queue;
41 $this->queue[] = $task;
46 while ($task = array_shift($this->queue)) {
|
| H A D | functions.php | 24 function queue(TaskQueueInterface $assign = null) function
26 return Utils::queue($assign);
|
| H A D | FulfilledPromise.php | 35 $queue = Utils::queue();
36 $p = new Promise([$queue, 'run']);
38 $queue->add(static function () use ($p, $value, $onFulfilled) {
|
| H A D | Promise.php | 151 Utils::queue()->add(static function () use ($id, $value, $handlers) {
235 Utils::queue()->run();
|
| /plugin/authgooglesheets/vendor/monolog/monolog/ |
| H A D | CHANGELOG.md | 146 * Added SqsHandler to send log records to an AWS SQS queue
|
| /plugin/authgooglesheets/vendor/guzzlehttp/guzzle/src/Handler/ |
| H A D | CurlMultiHandler.php | 118 P\queue()->run();
138 $queue = P\queue();
140 while ($this->handles || !$queue->isEmpty()) {
|
| H A D | MockHandler.php | 17 private $queue = []; variable in GuzzleHttp\\Handler\\MockHandler
34 array $queue = null, argument
46 * @param array $queue
51 array $queue = null, argument
58 if ($queue) {
59 call_user_func_array([$this, 'append'], $queue);
65 if (!$this->queue) {
75 $response = array_shift($this->queue);
140 $this->queue[] = $value;
175 return count($this->queue);
[all …]
|
| /plugin/authgooglesheets/vendor/guzzlehttp/guzzle/ |
| H A D | CHANGELOG.md | 27 * Improvement: Added support for reset internal queue in MockHandler. [#2143](https://github.com/gu…
880 * Added the ability to queue CurlExceptions to the MockPlugin
1227 * Adding generic batching system (replaces the batch queue plugin and command set)
|
| /plugin/authgooglesheets/vendor/guzzlehttp/promises/ |
| H A D | README.md | 415 asynchronously using a task queue. When waiting on promises synchronously, the
416 task queue will be automatically run to ensure that the blocking promise and
418 event loop, you will need to run the task queue on each tick of the loop. If
419 you do not run the task queue, then promises will not be resolved.
421 You can run the task queue using the `run()` method of the global task queue
425 // Get the global task queue
426 $queue = GuzzleHttp\Promise\Utils::queue();
427 $queue->run();
434 $loop->addPeriodicTimer(0, [$queue, 'run']);
512 | `queue` | `Utils::queue` |
|
| /plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/ClientProtocolHandler/ |
| H A D | ClientBasicHandler.php | 56 $queue = $context->getQueue();
58 $queue->sendMessage($message);
60 return $queue->getMessage($message->getMessageId());
66 * @param ClientQueue $queue
72 public function handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options): ?LdapMessageResponse
55 handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options) global() argument
|
| H A D | ClientSearchHandler.php | 59 * @param ClientQueue $queue
68 public function handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options): ?LdapMessageResponse
78 $messageFrom = $queue->getMessage($messageTo->getMessageId());
92 return parent::handleResponse($messageTo, $finalResponse, $queue, $options);
48 handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options) global() argument
|
| H A D | ClientStartTlsHandler.php | 31 * @param ClientQueue $queue
37 public function handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options): ?LdapMessageResponse
48 $queue->encrypt();
30 handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options) global() argument
|
| H A D | ClientUnbindHandler.php | 35 $queue = $context->getQueue();
37 $queue->sendMessage($message);
38 $queue->close();
|
| H A D | MessageCreationTrait.php | 25 protected function makeRequest(LdapQueue $queue, RequestInterface $request, array $controls): LdapMessageRequest
28 $queue->generateId(),
24 makeRequest(LdapQueue $queue, RequestInterface $request, array $controls) global() argument
|
| H A D | ResponseHandlerInterface.php | 29 public function handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options): ?LdapMessageResponse;
28 handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options) global() argument
|
| /plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/ |
| H A D | ClientProtocolHandler.php | 56 protected $queue;
78 public function __construct(array $options, ClientQueue $queue = null, SocketPool $pool = null, ClientProtocolHandlerFactory $clientProtocolHandlerFactory = null)
84 $this->queue = $queue;
155 $this->queue(),
165 $this->queue(),
173 $this->queue()->close();
195 return ($this->queue !== null && $this->queue->isConnected());
201 protected function queue()
50 protected $queue; global() variable in FreeDSx\\Ldap\\Protocol\\ClientProtocolHandler
72 __construct(array $options, ClientQueue $queue = null, SocketPool $pool = null, ClientProtocolHandlerFactory $clientProtocolHandlerFactory = null) global() argument
178 protected function queue(): ClientQueue global() function in FreeDSx\\Ldap\\Protocol\\ClientProtocolHandler
[all...] |
| /plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/ServerProtocolHandler/ |
| H A D | BindHandlerInterface.php | 32 public function handleBind(LdapMessageRequest $message, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options): TokenInterface;
31 handleBind(LdapMessageRequest $message, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options) global() argument
|
| H A D | ServerAnonBindHandler.php | 34 * @param ServerQueue $queue
41 public function handleBind(LdapMessageRequest $message, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options): TokenInterface
52 $queue->sendMessage($this->responseFactory->getStandardResponse($message));
31 handleBind(LdapMessageRequest $message, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options) global() argument
|
| H A D | ServerBindHandler.php | 37 public function handleBind(LdapMessageRequest $message, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options): TokenInterface
50 $queue->sendMessage($this->responseFactory->getStandardResponse($message));
34 handleBind(LdapMessageRequest $message, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options) global() argument
|