\cURLRequestsQueue

The EventDispatcherInterface is the central point of Symfony's event listener system.

Listeners are registered on the manager and events are dispatched through the manager.

Summary

Methods
Properties
Constants
dispatch()
getListeners()
hasListeners()
addListener()
removeListener()
addSubscriber()
removeSubscriber()
__construct()
__destruct()
getDefaultOptions()
setDefaultOptions()
getHandle()
attach()
detach()
count()
send()
socketPerform()
socketSelect()
No public properties found
No constants found
doDispatch()
read()
getRequestsNotRunning()
$defaultOptions
$mh
$runningCount
$queue
$running
N/A
sortListeners()
$listeners
$sorted
N/A

Properties

$defaultOptions

$defaultOptions : \cURL\Options

Type

\cURL\Options — Default options for new Requests attached to RequestsQueue

$mh

$mh : resource

Type

resource — cURL multi handler

$runningCount

$runningCount : integer

Type

integer — Amount of requests running

$queue

$queue : array<mixed,\cURL\Request>

Type

array<mixed,\cURL\Request> — Array of requests attached

$running

$running : array

Type

array — Array of requests running

$listeners

$listeners : 

Type

$sorted

$sorted : 

Type

Methods

dispatch()

dispatch(string  $eventName, \Symfony\Component\EventDispatcher\Event  $event = null) : \Symfony\Component\EventDispatcher\Event

Dispatches an event to all registered listeners.

Parameters

string $eventName

The name of the event to dispatch. The name of the event is the name of the method that is invoked on listeners.

\Symfony\Component\EventDispatcher\Event $event

The event to pass to the event handlers/listeners. If not supplied, an empty Event instance is created.

Returns

\Symfony\Component\EventDispatcher\Event

getListeners()

getListeners(string  $eventName = null) : array

Gets the listeners of a specific event or all listeners sorted by descending priority.

Parameters

string $eventName

The name of the event

Returns

array —

The event listeners for the specified event, or all event listeners by event name

hasListeners()

hasListeners(string  $eventName = null) : boolean

Checks whether an event has any registered listeners.

Parameters

string $eventName

The name of the event

Returns

boolean —

true if the specified event has any listeners, false otherwise

addListener()

addListener(string  $eventName, callable  $listener, integer  $priority) 

Adds an event listener that listens on the specified events.

Parameters

string $eventName

The event to listen on

callable $listener

The listener

integer $priority

The higher this value, the earlier an event listener will be triggered in the chain (defaults to 0)

removeListener()

removeListener(string  $eventName, callable  $listener) 

Removes an event listener from the specified events.

Parameters

string $eventName

The event to remove a listener from

callable $listener

The listener to remove

addSubscriber()

addSubscriber(\Symfony\Component\EventDispatcher\EventSubscriberInterface  $subscriber) 

Adds an event subscriber.

The subscriber is asked for all the events he is interested in and added as a listener for these events.

Parameters

\Symfony\Component\EventDispatcher\EventSubscriberInterface $subscriber

The subscriber.

__construct()

__construct() 

Initializes curl_multi handler

__destruct()

__destruct() : void

Destructor, closes curl_multi handler

getDefaultOptions()

getDefaultOptions() : \cURL\Options

Returns cURL\Options object with default request's options

Returns

\cURL\Options

setDefaultOptions()

setDefaultOptions(\cURL\Options  $defaultOptions) : void

Overrides default options with given Options object

Parameters

\cURL\Options $defaultOptions

New options

getHandle()

getHandle() : resource

Get cURL multi handle

Returns

resource

attach()

attach(\cURL\Request  $request) : self

Attach request to queue.

Parameters

\cURL\Request $request

Request to add

Returns

self

detach()

detach(\cURL\Request  $request) : self

Detach request from queue.

Parameters

\cURL\Request $request

Request to remove

Returns

self

count()

count() : integer

Returns count of handles in queue

Returns

integer —

Handles count

send()

send() : void

Executes requests in parallel

socketPerform()

socketPerform() : boolean

Download available data on socket.

Throws

\cURL\Exception

Returns

boolean —

TRUE when there are any requests on queue, FALSE when finished

socketSelect()

socketSelect(float|integer  $timeout = 1) : boolean

Waits until activity on socket On success, returns TRUE. On failure, this function will return FALSE on a select failure or timeout (from the underlying select system call)

Parameters

float|integer $timeout

Maximum time to wait

Throws

\cURL\Exception

Returns

boolean

doDispatch()

doDispatch(array<mixed,callable>  $listeners, string  $eventName, \Symfony\Component\EventDispatcher\Event  $event) 

Triggers the listeners of an event.

This method can be overridden to add functionality that is executed for each listener.

Parameters

array<mixed,callable> $listeners

The event listeners.

string $eventName

The name of the event to dispatch.

\Symfony\Component\EventDispatcher\Event $event

The event object to pass to the event handlers/listeners.

read()

read() : integer

Processes handles which are ready and removes them from pool.

Returns

integer —

Amount of requests completed

getRequestsNotRunning()

getRequestsNotRunning() : array<mixed,\cURL\Request>

Returns requests present in $queue but not in $running

Returns

array<mixed,\cURL\Request> —

Array of requests

sortListeners()

sortListeners(string  $eventName) 

Sorts the internal list of listeners for the given event by priority.

Parameters

string $eventName

The name of the event.