private void ensurePullAndPushRunning() {
        log.trace("State should be PLAYING to running this task: {}", subscriberStream.getState());
        if (pullMode && pullAndPush == null && subscriberStream.getState() == StreamState.PLAYING) {
            // client buffer is at least 100ms
            pullAndPush = subscriberStream.scheduleWithFixedDelay(new PullAndPushRunnable(), 10);
        }
    }
private void ensurePullAndPushRunning ( ) { log . trace ( "State should be PLAYING to running this task: {}" , subscriberStream . getState ( ) ) ; if ( pullMode && pullAndPush == null && subscriberStream . getState ( ) == StreamState . PLAYING ) { pullAndPush = subscriberStream . scheduleWithFixedDelay ( new PullAndPushRunnable ( ) , 10 ) ; } }
Make sure the pull and push processing is running.