This helps eliminate race and sequence gap between adding a subscriber and terminating concurrently without the use of CountDownLatch.