public final void accept ( T value ) { if ( GATE_UPDATER . get ( this ) == GATE_CLOSED ) { onDrop ( value ) ; return ; } onAccept ( value ) ; onNotification ( ) ; }
Notification callback method accepting a connection for a value . Triggers emission if the gate is open and the current call to this method is the last expected notification .