本文整理了Java中reactor.util.annotation.Nullable.<init>()方法的一些代码示例，展示了Nullable.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Nullable.<init>()方法的具体详情如下：
包路径：reactor.util.annotation.Nullable
类名称：Nullable
方法名：<init>

Nullable.<init>介绍

暂无

代码示例

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Consumer<? super Throwable> onErrorCall() {
  return onErrorCall;
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Runnable onCancelCall() {
  return onCancelCall;
}

代码示例来源：origin: reactor/reactor-core

@Nullable
@Override
public Subscription getSubscription() {
  return null;
}

代码示例来源：origin: reactor/reactor-core

private AssemblySnapshot(boolean checkpointed, @Nullable String description, Supplier<String> assemblyInformationSupplier) {
  this.checkpointed = checkpointed;
  this.description = description;
  this.assemblyInformationSupplier = assemblyInformationSupplier;
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public T poll() {
  int i = index;
  T[] a = array;
  if (i != a.length) {
    T t = Objects.requireNonNull(a[i], "Array returned null value");
    index = i + 1;
    return t;
  }
  return null;
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.ACTUAL) {
    return main;
  }
  return super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
  @Nullable
  public Object scanUnsafe(Attr key) {
    if (key == Attr.TERMINATED || key == Attr.CANCELLED) return terminado;
    return InnerProducer.super.scanUnsafe(key);
  }
}

代码示例来源：origin: reactor/reactor-core

@Override
  @Nullable
  public Object scanUnsafe(Attr key) {
    if (key == Attr.PARENT) return s;
    if (key == Attr.TERMINATED) return done;
    return InnerOperator.super.scanUnsafe(key);
  }
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return s;
  if (key == Attr.REQUESTED_FROM_DOWNSTREAM) return requested;
  if (key == Attr.TERMINATED) return done;
  if (key == Attr.CANCELLED) return cancelled;
  if (key == Attr.BUFFERED) return value != null ? 1 : 0;
  if (key == Attr.ERROR) return error;
  if (key == Attr.PREFETCH) return Integer.MAX_VALUE;
  return InnerOperator.super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public R poll() {
  SourceAndArray e = queue.poll();
  if (e == null) {
    return null;
  }
  R r = combiner.apply(e.array);
  e.source.requestOne();
  return r;
}

代码示例来源：origin: reactor/reactor-core

@Override
  @Nullable
  public Object scanUnsafe(Attr key) {
    if (key == Attr.PARENT) return  s;
    if (key == Attr.ACTUAL) return parent;
    if (key == Attr.CANCELLED) return s == Operators.cancelledSubscription();
    if (key == Attr.PREFETCH) return prefetch;
    return null;
  }
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return parent;
  if (key == Attr.TERMINATED) return done;
  if (key == Attr.CANCELLED) return cancelled;
  if (key == Attr.ERROR) return error;
  if (key == Attr.BUFFERED) return queue != null ? queue.size() : 0;
  if (key == Attr.REQUESTED_FROM_DOWNSTREAM) return requested;
  return InnerProducer.super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return s;
  if (key == Attr.TERMINATED) return done;
  return InnerOperator.super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return s;
  if (key == Attr.TERMINATED) return done;
  if (key == Attr.CANCELLED) return cancelled;
  if (key == Attr.PREFETCH) return prefetch;
  if (key == Attr.BUFFERED) return queue != null ? queue.size() : 0;
  if (key == Attr.ERROR) return error;
  if (key == Attr.DELAY_ERROR) return true;
  return FluxConcatMapSupport.super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return s;
  if (key == Attr.TERMINATED) return done;
  return InnerOperator.super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Nullable
@Override
public Object scanUnsafe(Attr key) {
  if (key == Attr.NAME) {
    return name;
  }
  if (key == Attr.TAGS && tags != null) {
    return tags.stream();
  }
  return super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.DELAY_ERROR) return true;
  if (key == Attr.ERROR) return error;
  return super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return s;
  return super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
@Nullable
public Object scanUnsafe(Attr key) {
  if (key == Attr.PARENT) return s;
  if (key == Attr.TERMINATED) return done;
  if (key == Attr.REQUESTED_FROM_DOWNSTREAM) return requested;
  if (key == Attr.ERROR) return error;
  if (key == Attr.CANCELLED) return cancelled;
  if (key == Attr.BUFFERED) return size();
  return InnerOperator.super.scanUnsafe(key);
}

代码示例来源：origin: reactor/reactor-core

@Override
  @Nullable
  final public T poll() {
    try {
      return qs.poll();
    }
    catch (final Throwable ex) {
      Exceptions.throwIfFatal(ex);
      throw Exceptions.propagate(fail(ex));
    }
  }
}