Class Channels
- java.lang.Object
-
- org.apache.maven.surefire.api.util.internal.Channels
-
public final class Channels extends java.lang.Object
ConvertsOutputStream
,PrintStream
,InputStream
to the JavaChannel
.
We do not use the Java's utility classChannels
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
-
-
Field Summary
Fields Modifier and Type Field Description private static int
BUFFER_SIZE
-
Constructor Summary
Constructors Modifier Constructor Description private
Channels()
-
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)
private static java.nio.channels.ReadableByteChannel
newChannel(java.io.InputStream is, int bufferSize)
static java.nio.channels.WritableByteChannel
newChannel(java.io.OutputStream out)
private static WritableBufferedByteChannel
newChannel(java.io.OutputStream out, int bufferSize)
static java.io.InputStream
newInputStream(java.nio.channels.AsynchronousByteChannel channel)
static java.io.OutputStream
newOutputStream(java.nio.channels.AsynchronousByteChannel channel)
-
-
-
Field Detail
-
BUFFER_SIZE
private static final int BUFFER_SIZE
- See Also:
- Constant Field Values
-
-
Method Detail
-
newChannel
public static java.nio.channels.WritableByteChannel newChannel(@Nonnull java.io.OutputStream out)
-
newBufferedChannel
public static WritableBufferedByteChannel newBufferedChannel(@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)
-
newChannel
private static java.nio.channels.ReadableByteChannel newChannel(@Nonnull java.io.InputStream is, @Nonnegative int bufferSize)
-
newChannel
private static WritableBufferedByteChannel newChannel(@Nonnull java.io.OutputStream out, @Nonnegative int bufferSize)
-
-