final class org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer extends org.apache.hc.core.http.nio.entity.AbstractBinAsyncEntityConsumer
{
private final org.apache.hc.core.util.ByteArrayBuffer buffer;
public void <init>()
{
org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer v;
org.apache.hc.core.util.ByteArrayBuffer v;
v := @this: org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer;
specialinvoke v.<org.apache.hc.core.http.nio.entity.AbstractBinAsyncEntityConsumer: void <init>()>();
v = new org.apache.hc.core.util.ByteArrayBuffer;
specialinvoke v.<org.apache.hc.core.util.ByteArrayBuffer: void <init>(int)>(1024);
v.<org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer: org.apache.hc.core.util.ByteArrayBuffer buffer> = v;
return;
}
protected void streamStart(org.apache.hc.core.http.ContentType) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer v;
org.apache.hc.core.http.ContentType v;
v := @this: org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer;
v := @parameter: org.apache.hc.core.http.ContentType;
return;
}
protected int capacityIncrement()
{
org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer v;
v := @this: org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer;
return 2147483647;
}
protected void data(java.nio.ByteBuffer, boolean) throws java.io.IOException
{
org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer v;
byte[] v;
java.nio.ByteBuffer v;
org.apache.hc.core.util.ByteArrayBuffer v, v;
byte v;
int v, v, v, v;
boolean v, v, v;
v := @this: org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: boolean;
if v != null goto label;
return;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasArray()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer: org.apache.hc.core.util.ByteArrayBuffer buffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int arrayOffset()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
virtualinvoke v.<org.apache.hc.core.util.ByteArrayBuffer: void append(byte[],int,int)>(v, v, v);
goto label;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = v.<org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer: org.apache.hc.core.util.ByteArrayBuffer buffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte get()>();
virtualinvoke v.<org.apache.hc.core.util.ByteArrayBuffer: void append(int)>(v);
goto label;
label:
return;
}
protected byte[] generateContent() throws java.io.IOException
{
org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer v;
byte[] v;
org.apache.hc.core.util.ByteArrayBuffer v;
v := @this: org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer;
v = v.<org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer: org.apache.hc.core.util.ByteArrayBuffer buffer>;
v = virtualinvoke v.<org.apache.hc.core.util.ByteArrayBuffer: byte[] toByteArray()>();
return v;
}
public void releaseResources()
{
org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer v;
org.apache.hc.core.util.ByteArrayBuffer v;
v := @this: org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer;
v = v.<org.apache.hc.client.http.async.methods.SimpleAsyncEntityConsumer: org.apache.hc.core.util.ByteArrayBuffer buffer>;
virtualinvoke v.<org.apache.hc.core.util.ByteArrayBuffer: void clear()>();
return;
}
}