Class Channels


  • public final class Channels
    extends java.lang.Object
    Converts OutputStream, PrintStream, InputStream to the Java Channel.
    We do not use the Java's utility class Channels because the utility closes the stream as soon as the particular Thread is interrupted. If the frameworks (Zookeeper, Netty) interrupts the thread, the communication channels become closed and the JVM hangs. Therefore we developed internal utility which is safe for the Surefire.
    Since:
    3.0.0-M5
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.nio.channels.ReadableByteChannel newBufferedChannel​(java.io.InputStream is)  
      static WritableBufferedByteChannel newBufferedChannel​(java.io.OutputStream out)  
      static java.nio.channels.ReadableByteChannel newChannel​(java.io.InputStream is)  
      static java.nio.channels.WritableByteChannel newChannel​(java.io.OutputStream out)  
      static java.io.InputStream newInputStream​(java.nio.channels.AsynchronousByteChannel channel)  
      static java.io.OutputStream newOutputStream​(java.nio.channels.AsynchronousByteChannel channel)  
      • Methods inherited from class java.lang.Object

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

      • newChannel

        public static java.nio.channels.WritableByteChannel newChannel​(@Nonnull
                                                                       java.io.OutputStream out)
      • newChannel

        public static java.nio.channels.ReadableByteChannel newChannel​(@Nonnull
                                                                       java.io.InputStream is)
      • newBufferedChannel

        public static java.nio.channels.ReadableByteChannel newBufferedChannel​(@Nonnull
                                                                               java.io.InputStream is)
      • newOutputStream

        public static java.io.OutputStream newOutputStream​(java.nio.channels.AsynchronousByteChannel channel)
      • newInputStream

        public static java.io.InputStream newInputStream​(java.nio.channels.AsynchronousByteChannel channel)