private boolean predicateApplies ( Subscriber < ? > s , Object message ) { if ( s instanceof PredicatedSubscriber && ! ( ( PredicatedSubscriber < ? > ) s ) . appliesO ( message ) ) { return false ; } return true ; }
Checks to see if the subscriber is a predicated subscriber and if it applies .