public void notifyRecordIsAvailable ( int channelIndex ) { this . availableChannels . add ( Integer . valueOf ( channelIndex ) ) ; RecordAvailabilityListener < T > listener = this . recordAvailabilityListener . get ( ) ; if ( listener != null ) { listener . reportRecordAvailability ( this ) ; } }
Notify the gate that the channel with the given index has at least one record available .