@ AsCallback public void _rq ( long l , int id ) { if ( doOnSubscribe != null ) { doOnSubscribe . add ( ( ) -> _rq ( l , id ) ) ; } else { SubscriberEntry se = getSE ( id ) ; if ( se != null ) { // ignore unknown subscribers se . addCredits ( l ) ; } else { Log . Warn ( this , "ignored credits " + l + " on id " + id ) ; } emitRequestNext ( ) ; } }
private . remoted request next