Aggregator
Constructor Summary
Public Constructor | ||
public |
constructor(size: *, processor: *, observer: *) |
Method Summary
Public Methods | ||
public |
addEvent(event: *, cb: *) Add an event, which will be assigned to a bucket |
|
public |
bucket(d: *): * Gets the current bucket or returns a new one. |
|
public |
done() Forces the current bucket to emit |
|
public |
onEmit(cb: *) Set the emit callback after the constructor |
Public Constructors
public constructor(size: *, processor: *, observer: *) source
Params:
Name | Type | Attribute | Description |
size | * | ||
processor | * | ||
observer | * |
Public Methods
public addEvent(event: *, cb: *) source
Add an event, which will be assigned to a bucket
Params:
Name | Type | Attribute | Description |
event | * | ||
cb | * |
public bucket(d: *): * source
Gets the current bucket or returns a new one.
If a new bucket is generated the result of the old bucket is emitted automatically.
Params:
Name | Type | Attribute | Description |
d | * |
Return:
* |
public onEmit(cb: *) source
Set the emit callback after the constructor
Params:
Name | Type | Attribute | Description |
cb | * |