Class TestProvidingInputStream

    • Field Detail

      • barrier

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

        private final java.util.Queue<Command> commands
      • closed

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

        private final java.util.Queue<java.lang.String> testClassNames
    • Constructor Detail

      • TestProvidingInputStream

        public TestProvidingInputStream​(java.util.Queue<java.lang.String> testClassNames)
        C'tor
        Parameters:
        testClassNames - source of the tests to be read from this stream
    • Method Detail

      • testSetFinished

        void testSetFinished()
        For testing purposes.
      • 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()
      • provideNewTest

        public void provideNewTest()
        Signal that a new test is to be provided.
      • 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
      • awaitNextTest

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