Reworking concurrency approach in reactor