Title / Description
Code final class MonoJust<T> extends Mono<T> implements Fuseable.ScalarCallable<T>, Fuseable { final T value; MonoJust(T value) { this.value = Objects.requireNonNull(value, "value"); } @Override public T call() { return value; } @Override public T block(Duration m) { return value; } @Override public T block() { return value; } @Override public void subscribe(Subscriber<? super T> s) { s.onSubscribe(Operators.scalarSubscription(s, value)); } }
Author
Highlight as C C++ CSS Clojure Delphi ERb Groovy (beta) HAML HTML JSON Java JavaScript PHP Plain text Python Ruby SQL XML YAML diff code