@ SuppressWarnings ( "unchecked" ) MonoDelayUntil < T > copyWithNewTriggerGenerator ( boolean delayError , Function < ? super T , ? extends Publisher < ? > > triggerGenerator ) { Objects . requireNonNull ( triggerGenerator , "triggerGenerator" ) ; Function < ? super T , ? extends Publisher < ? > > [ ] oldTriggers = this . otherGenerators ; Function < ? super T , ? extends Publisher < ? > > [ ] newTriggers = new Function [ oldTriggers . length + 1 ] ; System . arraycopy ( oldTriggers , 0 , newTriggers , 0 , oldTriggers . length ) ; newTriggers [ oldTriggers . length ] = triggerGenerator ; return new MonoDelayUntil <> ( this . source , newTriggers ) ; }
Add a trigger generator to wait for .