private void sendFlush ( final SignalFlush signalFlush ) { for ( Endpoint endpoint : endpoints ) { if ( endpoint != null ) { endpoint . send ( signalFlush ) ; } } }
Helper method to send the flush signal to all endpoints .