private void timeout ( long barrierId ) { if ( this . barrierId == barrierId && ! broken ) { broken = true ; parties . forEach ( session -> getSession ( session ) . accept ( client -> client . broken ( barrierId ) ) ) ; } }
Times out the given barrier instance .