protected final boolean validate ( Subscriber < ? > [ ] subscribers ) { int p = parallelism ( ) ; if ( subscribers . length != p ) { IllegalArgumentException iae = new IllegalArgumentException ( "parallelism = " + "" + p + ", subscribers = " + subscribers . length ) ; for ( Subscriber < ? > s : subscribers ) { Operators . error ( s , iae ) ; } return false ; } return true ; }
Validates the number of subscribers and returns true if their number matches the parallelism level of this ParallelFlux .