public synchronized void waitForData ( ) { while ( this . flushers . isEmpty ( ) && this . isNotStopped ( ) ) { try { this . wait ( ) ; } catch ( final InterruptedException e ) { Thread . currentThread ( ) . interrupt ( ) ; throw new RuntimeException ( e ) ; } } }
wait for the data