ArchaiusSystemDisruptionBudgetResolver implements SystemDisruptionBudgetResolver { @Override public Flux<SystemDisruptionBudget> resolve() { return budgetEmitter; } @Inject  ArchaiusSystemDisruptionBudgetResolver(PropertyRepository repository); @PreDestroy void shutdown(); @Override Flux<SystemDisruptionBudget> resolve(); static final String PROPERTY_KEY; }
@Test public void testResolve() throws Exception { property.set(toJson(DESCRIPTOR_1_1)); ArchaiusSystemDisruptionBudgetResolver resolver = new ArchaiusSystemDisruptionBudgetResolver(repository); resolver.resolve().subscribe(testSubscriber); assertThat(testSubscriber.takeNext()).isEqualTo(toDisruptionBudget(DESCRIPTOR_1_1)); property.set(toJson(DESCRIPTOR_2_2)); assertThat(testSubscriber.takeNext()).isEqualTo(toDisruptionBudget(DESCRIPTOR_2_2)); }