Class TestLessInputStream

    • 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

      • provideNewTest

        public void provideNewTest()
        Description copied from interface: NotifiableTestStream
        Forked jvm notifies master process to provide a new test.
        Notifies TestProvidingInputStream in order to dispatch a new test back to the forked jvm (particular fork which hits this call); or do nothing in TestLessInputStream.
      • 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()
      • isClosed

        public boolean isClosed()
      • close

        public void close()
      • 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