Class BlockingUtils


  • @Experimental
    public final class BlockingUtils
    extends java.lang.Object
    Utility functions relating to blocking types.

    Not intended to be part of the public API.

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private BlockingUtils()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void awaitForComplete​(java.util.concurrent.CountDownLatch latch, Subscription subscription)
      Blocks and waits for a Subscription to complete.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • BlockingUtils

        private BlockingUtils()
    • Method Detail

      • awaitForComplete

        @Experimental
        public static void awaitForComplete​(java.util.concurrent.CountDownLatch latch,
                                            Subscription subscription)
        Blocks and waits for a Subscription to complete.
        Parameters:
        latch - a CountDownLatch
        subscription - the Subscription to wait on.