@Override
    public void addEveryState(StateEvent stateEvent) {
        LogicalStreamPreState state = (LogicalStreamPreState) stateHolder.getState();
        lock.lock();
        try {
            StateEvent clonedEvent = stateEventCloner.copyStateEvent(stateEvent);
            clonedEvent.setType(ComplexEvent.Type.CURRENT);
            for (int i = stateId; i < clonedEvent.getStreamEvents().length; i++) {
                clonedEvent.setEvent(i, null);
            }
            state.getNewAndEveryStateEventList().add(clonedEvent);
            // Start the scheduler
            state.lastScheduledTime = stateEvent.getTimestamp() + waitingTime;
            scheduler.notifyAt(state.lastScheduledTime);
        } finally {
            lock.unlock();
            stateHolder.returnState(state);
        }
    }
Construct an AbsentStreamPreStateProcessor object.

@param stateType   PATTERN or SEQUENCE
@param waitingTime the waiting time defined by 'for' keyword
modules/siddhi-core/src/main/java/io/siddhi/core/query/input/stream/state/AbsentStreamPreStateProcessor.java