- .flatMap(ric -> createRicData(ric)) //
- .flatMap(ricData -> checkRicState(ricData)) //
- .flatMap(ricData -> checkRicPolicies(ricData)) //
- .flatMap(ricData -> checkRicPolicyTypes(ricData));
+ .flatMap(this::createRicData) //
+ .flatMap(this::checkRicState) //
+ .doOnNext(ricData -> ricData.ric.getLock().lockBlocking(LockType.EXCLUSIVE)) //
+ .flatMap(this::checkRicPolicies) //
+ .doOnNext(ricData -> ricData.ric.getLock().unlock()) //
+ .flatMap(this::checkRicPolicyTypes); //