Class TestLessInputStream

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, NotifiableTestStream

    public final class TestLessInputStream
    extends AbstractCommandStream
    Dispatches commands without tests.
    Since:
    2.19
    • Field Detail

      • barrier

        private final java.util.concurrent.Semaphore barrier
      • closed

        private final java.util.concurrent.atomic.AtomicBoolean closed
      • immediateCommands

        private final java.util.Queue<Command> immediateCommands
      • cachableCommands

        private java.util.Iterator<Command> cachableCommands
    • Method Detail

      • skipSinceNextTest

        public void skipSinceNextTest()
        Description copied from interface: NotifiableTestStream
        Sends an event to a fork jvm in order to skip tests. Returns immediately without blocking.
      • shutdown

        public void shutdown​(Shutdown shutdownType)
      • noop

        public void noop()
      • acknowledgeByeEventReceived

        public void acknowledgeByeEventReceived()
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Overrides:
        close in class java.io.InputStream
      • availablePermits

        int availablePermits()
        For testing purposes only.
        Returns:
        permits used internally by beforeNextCommand()
      • awaitNextCommand

        private void awaitNextCommand()
                               throws java.io.IOException
        Throws:
        java.io.IOException