class org.buildobjects.process.StreamConsumerConsumptionThread extends java.lang.Object implements org.buildobjects.process.OutputConsumptionThread
{
private final org.buildobjects.process.EventSink eventSink;
private final org.buildobjects.process.StreamConsumer stdout;
private java.lang.Thread thread;
private java.lang.Throwable throwable;
public void <init>(org.buildobjects.process.EventSink, org.buildobjects.process.StreamConsumer)
{
org.buildobjects.process.StreamConsumerConsumptionThread v;
org.buildobjects.process.StreamConsumer v;
org.buildobjects.process.EventSink v;
v := @this: org.buildobjects.process.StreamConsumerConsumptionThread;
v := @parameter: org.buildobjects.process.EventSink;
v := @parameter: org.buildobjects.process.StreamConsumer;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.buildobjects.process.StreamConsumerConsumptionThread: org.buildobjects.process.EventSink eventSink> = v;
v.<org.buildobjects.process.StreamConsumerConsumptionThread: org.buildobjects.process.StreamConsumer stdout> = v;
return;
}
public void startConsumption(java.io.InputStream)
{
org.buildobjects.process.StreamConsumerConsumptionThread v;
org.buildobjects.process.StreamConsumerConsumptionThread$1 v;
java.lang.Thread v, v;
java.io.InputStream v;
v := @this: org.buildobjects.process.StreamConsumerConsumptionThread;
v := @parameter: java.io.InputStream;
v = new java.lang.Thread;
v = new org.buildobjects.process.StreamConsumerConsumptionThread$1;
specialinvoke v.<org.buildobjects.process.StreamConsumerConsumptionThread$1: void <init>(org.buildobjects.process.StreamConsumerConsumptionThread,java.io.InputStream)>(v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
v.<org.buildobjects.process.StreamConsumerConsumptionThread: java.lang.Thread thread> = v;
v = v.<org.buildobjects.process.StreamConsumerConsumptionThread: java.lang.Thread thread>;
virtualinvoke v.<java.lang.Thread: void start()>();
return;
}
public void join() throws java.lang.InterruptedException
{
org.buildobjects.process.StreamConsumerConsumptionThread v;
java.lang.Thread v;
v := @this: org.buildobjects.process.StreamConsumerConsumptionThread;
v = v.<org.buildobjects.process.StreamConsumerConsumptionThread: java.lang.Thread thread>;
virtualinvoke v.<java.lang.Thread: void join()>();
return;
}
public void interrupt()
{
org.buildobjects.process.StreamConsumerConsumptionThread v;
java.lang.Thread v;
v := @this: org.buildobjects.process.StreamConsumerConsumptionThread;
v = v.<org.buildobjects.process.StreamConsumerConsumptionThread: java.lang.Thread thread>;
virtualinvoke v.<java.lang.Thread: void interrupt()>();
return;
}
public java.lang.Throwable getThrowable()
{
java.lang.Throwable v;
org.buildobjects.process.StreamConsumerConsumptionThread v;
v := @this: org.buildobjects.process.StreamConsumerConsumptionThread;
v = v.<org.buildobjects.process.StreamConsumerConsumptionThread: java.lang.Throwable throwable>;
return v;
}
}