import Throttle from 'ex-stream/Throttle';
Throttles stream data
import Throttle from 'ex-stream/Throttle';
class DelayThrottle extends Throttle {
_throttling(data, next) {
setTimeout(1000, next);
}
}
Parameters:
options
:*
Class is abstract
_throttling(data: any)
Throttle stream data
Parameters:
data
:any