code: 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);
          }
      }
docs: Make sure the pull and push processing is running.