Package org.apache.maven.surefire.api.util.internal

Class Channels

java.lang.Object

org.apache.maven.surefire.api.util.internal.Channels

public final class Channels
extends 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

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	BUFFER_SIZE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Channels()

Method Summary

Modifier and Type	Method	Description
static ReadableByteChannel	newBufferedChannel(InputStream is)
static WritableBufferedByteChannel	newBufferedChannel(OutputStream out)
static ReadableByteChannel	newChannel(InputStream is)
private static ReadableByteChannel	newChannel(InputStream is, int bufferSize)
static WritableByteChannel	newChannel(OutputStream out)
private static WritableBufferedByteChannel	newChannel(OutputStream out, int bufferSize)
static InputStream	newInputStream(AsynchronousByteChannel channel)
static OutputStream	newOutputStream(AsynchronousByteChannel channel)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

BUFFER_SIZE

private static final int BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

Channels

private Channels()

Method Details

newChannel

public static WritableByteChannel newChannel(@Nonnull
 OutputStream out)

newBufferedChannel

public static WritableBufferedByteChannel newBufferedChannel(@Nonnull
 OutputStream out)

newChannel

public static ReadableByteChannel newChannel(@Nonnull
 InputStream is)

newBufferedChannel

public static ReadableByteChannel newBufferedChannel(@Nonnull
 InputStream is)

newOutputStream

public static OutputStream newOutputStream(AsynchronousByteChannel channel)

newInputStream

public static InputStream newInputStream(AsynchronousByteChannel channel)

newChannel

private static ReadableByteChannel newChannel(@Nonnull
 InputStream is,
 @Nonnegative
 int bufferSize)

newChannel

private static WritableBufferedByteChannel newChannel(@Nonnull
 OutputStream out,
 @Nonnegative
 int bufferSize)