@Override
    public void suspend() {
        // TODO unsubscribe from everything? And resubscribe on resume?
        super.suspend();
        if (executor != null) executor.shutdownNow();
        executorQueued.set(false);
    }
@Override
    public void suspend() {
       
        super.suspend();
        if (executor != null) executor.shutdownNow();
        executorQueued.set(false);
    }
@override public void suspend() { super.suspend(); if (executor != null) executor.shutdownnow(); executorqueued.set(false); }