Top Fields Constructors Methods
org.cservenak.streams

public Class CoderThread

extends Thread
Class Inheritance
Imports
java.io.*

Field Summary

Modifier and TypeField and Description
private final PipedInputStream
inSink

private final PipedOutputStream
outSink

private Throwable
throwable

private final Runnable
workhorse

Inherited from java.lang.Thread:
MAX_PRIORITYMIN_PRIORITYNORM_PRIORITY

Constructor Summary

AccessConstructor and Description
public
CoderThread(final Coder coder, final InputStream in)

public
CoderThread(final Coder coder, final OutputStream out)

Method Summary

Modifier and TypeMethod and Description
public void
checkForException()

protected boolean
close(Closeable closeable)

protected boolean
flush(Flushable flushable)

public PipedInputStream
getInputStreamSink()

public PipedOutputStream
getOutputStreamSink()

public Throwable
getThrowable()

public void
run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

This method is run by the thread when it executes.
Inherited from java.lang.Thread:
activeCountcheckAccessclonecountStackFramescurrentThreaddumpStackenumerategetAllStackTracesgetContextClassLoadergetDefaultUncaughtExceptionHandlergetIdgetNamegetPrioritygetStackTracegetStategetThreadGroupgetUncaughtExceptionHandlerholdsLockinterruptinterruptedisAliveisDaemonisInterruptedisVirtualjoinjoinjoinjoinofPlatformofVirtualonSpinWaitresumesetContextClassLoadersetDaemonsetDefaultUncaughtExceptionHandlersetNamesetPrioritysetUncaughtExceptionHandlersleepsleepsleepstartstartVirtualThreadstopsuspendthreadIdtoStringyield

Field Detail

inSinkback to summary
private final PipedInputStream inSink
outSinkback to summary
private final PipedOutputStream outSink
throwableback to summary
private Throwable throwable
workhorseback to summary
private final Runnable workhorse

Constructor Detail

CoderThreadback to summary
public CoderThread(final Coder coder, final InputStream in) throws IOException
CoderThreadback to summary
public CoderThread(final Coder coder, final OutputStream out) throws IOException

Method Detail

checkForExceptionback to summary
public void checkForException() throws IOException
closeback to summary
protected boolean close(Closeable closeable)
flushback to summary
protected boolean flush(Flushable flushable)
getInputStreamSinkback to summary
public PipedInputStream getInputStreamSink()
getOutputStreamSinkback to summary
public PipedOutputStream getOutputStreamSink()
getThrowableback to summary
public Throwable getThrowable()
runback to summary
public void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

Doc from java.lang.Thread.run.

This method is run by the thread when it executes. Subclasses of Thread may override this method.

This method is not intended to be invoked directly. If this thread is a platform thread created with a Runnable task then invoking this method will invoke the task's run method. If this thread is a virtual thread then invoking this method directly does nothing.