private boolean normal ( Publish p ) { boolean sent = false ; List < SubscriberParent > list = p . mapping . get ( p . message . getClass ( ) ) ; if ( list == null ) { return false ; } for ( SubscriberParent sp : list ) { Subscriber < ? > s = sp . getSubscriber ( ) ; if ( ! predicateApplies ( s , p . message ) ) { continue ; } s . receiveO ( p . message ) ; sent = true ; } return sent ; }
Iterates through the subscribers invoking the receiveO method .