@Test public void fromRSError() throws Exception { Publisher<Integer> rsPublisher = newMockRsPublisher((subscriber, __) -> subscriber.onError(DELIBERATE_EXCEPTION)); Future<Integer> future = fromReactiveStreamsPublisher(rsPublisher).firstOrElse(() -> null).toFuture(); expectedException.expect(instanceOf(ExecutionException.class)); expectedException.expectCause(sameInstance(DELIBERATE_EXCEPTION)); future.get(); }
public static <T> Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source) { return new RsToStPublisher<>(source); }
ReactiveStreamsAdapters { public static <T> Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source) { return new RsToStPublisher<>(source); } }
ReactiveStreamsAdapters { public static <T> Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source) { return new RsToStPublisher<>(source); } private  ReactiveStreamsAdapters(); }
ReactiveStreamsAdapters { public static <T> Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source) { return new RsToStPublisher<>(source); } private  ReactiveStreamsAdapters(); static Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source); static org.reactivestreams.Publisher<T> toReactiveStreamsPublisher(Publisher<T> publisher); static org.reactivestreams.Publisher<T> toReactiveStreamsPublisher(PublisherSource<T> source); }
ReactiveStreamsAdapters { public static <T> Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source) { return new RsToStPublisher<>(source); } private  ReactiveStreamsAdapters(); static Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source); static org.reactivestreams.Publisher<T> toReactiveStreamsPublisher(Publisher<T> publisher); static org.reactivestreams.Publisher<T> toReactiveStreamsPublisher(PublisherSource<T> source);  }