docs: private void emitLoop() {
          for (;;) {
              AppendOnlyLinkedArrayList<T> q;
              synchronized (this) {
                  q = queue;
                  if (q == null) {
                      emitting = false;
                      return;
                  }
                  queue = null;
              }
              q.accept(actual);
          }
      }