time/src/periodic.ts
Function makePeriodic
has 37 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
function makePeriodic(createOperator: () => OperatorArgs<any>) {
const {schedule, currentTime} = createOperator();
return function periodic(period: number): Stream<number> {
let stopped = false;
Function periodic
has 34 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
return function periodic(period: number): Stream<number> {
let stopped = false;
let lastEmitTime = 0;
function scheduleNextEvent(