@Test public void createFromError() { Eventual<String> eventual = Eventual.error(new JustATestException()); StepVerifier.create(eventual) .expectError(RuntimeException.class) .verify(); }
public static <T> Eventual<T> error(Throwable error) { return fromMono(Mono.error(error)); }
Eventual implements Publisher<T> { public static <T> Eventual<T> error(Throwable error) { return fromMono(Mono.error(error)); } }
Eventual implements Publisher<T> { public static <T> Eventual<T> error(Throwable error) { return fromMono(Mono.error(error)); } Eventual(Publisher<T> publisher); }
Eventual implements Publisher<T> { public static <T> Eventual<T> error(Throwable error) { return fromMono(Mono.error(error)); } Eventual(Publisher<T> publisher); static Eventual<T> of(T value); static Eventual<T> from(CompletionStage<T> completionStage); static Eventual<T> error(Throwable error); Eventual<R> map(Function<? super T, ? extends R> transformation); Eventual<R> flatMap(Function<? super T, ? extends Eventual<? extends R>> transformation); Eventual<T> onError(Function<Throwable, ? extends Eventual<? extends T>> errorHandler); @Override void subscribe(Subscriber<? super T> subscriber); }
Eventual implements Publisher<T> { public static <T> Eventual<T> error(Throwable error) { return fromMono(Mono.error(error)); } Eventual(Publisher<T> publisher); static Eventual<T> of(T value); static Eventual<T> from(CompletionStage<T> completionStage); static Eventual<T> error(Throwable error); Eventual<R> map(Function<? super T, ? extends R> transformation); Eventual<R> flatMap(Function<? super T, ? extends Eventual<? extends R>> transformation); Eventual<T> onError(Function<Throwable, ? extends Eventual<? extends T>> errorHandler); @Override void subscribe(Subscriber<? super T> subscriber);  }