Flux<String> policies = Flux.just(new String[] {POLICY_ID_1, POLICY_ID_2});
doReturn(Flux.error(new Exception("Unable to contact ric.")), policies).when(a1ClientMock)
.getPolicyIdentities(anyString());
Flux<String> policies = Flux.just(new String[] {POLICY_ID_1, POLICY_ID_2});
doReturn(Flux.error(new Exception("Unable to contact ric.")), policies).when(a1ClientMock)
.getPolicyIdentities(anyString());