- public Mono<String> deletePolicy(String nearRtRicUrl, String policyId) {
- getPolicies(nearRtRicUrl).removeId(policyId);
- return Mono.just("OK");
+ public Flux<String> deleteAllPolicies() {
+ this.policies.clear();
+ return mono("OK") //
+ .flatMapMany(Flux::just);
+ }
+
+ @Override
+ public Mono<String> getPolicyStatus(Policy policy) {
+ return mono("OK");
+ }
+
+ private <T> Mono<T> mono(T value) {
+ if (this.asynchDelay.isZero()) {
+ return Mono.just(value);
+ } else {
+ return Mono.create(monoSink -> asynchResponse(monoSink, value));
+ }