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