sandglass[WIP]
Aggregates data stream timeline as time window.
Usage
var Sandglass = ;var sandglass = ;
Sandglass
emit( data );
Send data to all SandStreams.
absoluteSlice( timespan );
Slices data stream timeline with timespan and aggregates each slice of data stream. Next aggregation starts after one aggregation ends, and another one starts again and again.
Arguments
- timespan(Number): slice size (millisecond).
Returns
(sandStream): Fires aggregate
event after stream aggregation.
emitter.on( 'aggregate', callback );
callback
gets an array of streaming data.
Example
var sandStream = sandglass; ;;;;;; sandStream;
relativeSlice( timespan );
Slices data stream timeline with timespan and aggregates each slice of data stream. The aggregation starts at each incoming data, and it ends after it takes the timespan. (Same as delayedCount)
Arguments
- timespan(Number): slice size (millisecond).
Returns
(sandStream): Fires aggregate
event after stream aggregation.
emitter.on( 'aggregate', callback );
callback
gets an array of streaming data.
Example
var sandStream = sandglass; ;;;;;; sandStream;
liveCount( timespan );
When data incomes, 'liveCount' reserve the data. At the same time 'liveCount' sends data as aggregation which was reserved untill at that time. Each data is disposed after it takes timespan.
Arguments
- timespan(Number): slice size (millisecond).
Returns
(sandStream): Fires aggregate
event after stream aggregation.
emitter.on( 'aggregate', callback );
callback
gets an array of reserved streaming data.
delayedCount( timespan );
Aliase of relativeSlice (Same as relativeSlice). When data incomes, 'delayedCount' reserve the data. After it takes timespan, 'delayedCount' sends data as aggregation which was reserved untill at that time, and then the data is disposed.
SandStream
on( event, listener );
Set event listener.
sandStream.on( 'aggregate', function( agg ) {...} )
off( event, listener );
Remove event listener.
stop();
Stop aggregation. GC works.
other methods
see EventEmitter2