Collector
Constructor Summary
| Public Constructor | ||
| public |
constructor(size: *, 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: *) |
|
Public Constructors
public constructor(size: *, observer: *) source
Params:
| Name | Type | Attribute | Description |
| size | * | ||
| 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
Params:
| Name | Type | Attribute | Description |
| cb | * |