final class Subscribers implements IteratorAggregate, Countable, JsonSerializable (View source)

internal  implementation detail of the catchup
 

A collection of the registered subscribers.

Currently only projections are the available subscribers, but when the concept is extended, other *Subscriber value objects will also be hold in this set. Like a possible "ListeningSubscriber" to only listen to events without the capabilities of a full-blown projection.

Methods

static Subscribers
fromArray(array $subscribers)

No description

static Subscribers
createEmpty()

No description

with(ProjectionSubscriber $subscriber)

No description

bool
contain(SubscriptionId $id)

No description

getIterator()

No description

int
count()

No description

iterable
jsonSerialize()

No description

Details

static Subscribers fromArray(array $subscribers)

No description

Parameters

array $subscribers

Return Value

Subscribers

static Subscribers createEmpty()

No description

Return Value

Subscribers

Subscribers with(ProjectionSubscriber $subscriber)

No description

Parameters

ProjectionSubscriber $subscriber

Return Value

Subscribers

ProjectionSubscriber get(SubscriptionId $id)

No description

Parameters

SubscriptionId $id

Return Value

ProjectionSubscriber

bool contain(SubscriptionId $id)

No description

Parameters

SubscriptionId $id

Return Value

bool

Traversable getIterator()

No description

Return Value

Traversable

int count()

No description

Return Value

int

iterable jsonSerialize()

No description

Return Value

iterable