### Question:
CryptoCompareService implements CryptoService { public static <T> Flux<T> provideResilience(Flux<T> input) { return input; } CryptoCompareService(); Flux<Map<String, Object>> eventsStream(); static Flux<T> provideResilience(Flux<T> input); static Flux<T> provideCaching(Flux<T> input); static final int CACHE_SIZE; }### Answer:
@Test public void verifyThatSupportIsolationAndResilience() { Flux<String> source = Flux.defer(() -> Flux.just("1", "2", "3") .mergeWith(Flux.error(new RuntimeException()))); StepVerifier.withVirtualTime(() -> CryptoCompareService.provideResilience(source) .take(6) ) .expectSubscription() .thenAwait(Duration.ofDays(10)) .expectNext("1", "2", "3") .expectNext("1", "2", "3") .expectComplete() .verify(); }