void emitNext(Object n){
  if (!fastPath) {
synchronized (this) {
      first=false;
      if (emitting) {
        if (queue == null) {
          queue=new ArrayList<Object>();
        }
        queue.add(n);
        return;
      }
    }
    fastPath=true;
  }
  NotificationLite.accept(actual,n);
}

void emitNext ( Object n ) { if ( ! fastPath ) { synchronized ( this ) { first = false ; if ( emitting ) { if ( queue == null ) { queue = new ArrayList < Object > ( ) ; } queue . add ( n ) ; return ; } } fastPath = true ; } NotificationLite . accept ( actual , n ) ; }
emits the given notificationlite value and prevents the emitfirst to run if not already run .
