public final Flux < T > repeat ( long numRepeat , BooleanSupplier predicate ) { if ( numRepeat < 0L ) { throw new IllegalArgumentException ( "numRepeat >= 0 required" ) ; } if ( numRepeat == 0 ) { return this ; } return defer ( ( ) -> repeat ( countingBooleanSupplier ( predicate , numRepeat ) ) ) ; }
Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription . A specified maximum of repeat will limit the number of re - subscribe .