public abstract class org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer extends java.lang.Object implements org.apache.hc.core.http.nio.AsyncDataConsumer
{
private static final java.nio.ByteBuffer EMPTY;
public void <init>()
{
org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer v;
v := @this: org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
protected abstract int capacityIncrement();
protected abstract void data(java.nio.ByteBuffer, boolean) throws java.io.IOException;
protected abstract void completed() throws java.io.IOException;
public final void updateCapacity(org.apache.hc.core.http.nio.CapacityChannel) throws java.io.IOException
{
int v;
org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer v;
org.apache.hc.core.http.nio.CapacityChannel v;
v := @this: org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer;
v := @parameter: org.apache.hc.core.http.nio.CapacityChannel;
v = virtualinvoke v.<org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer: int capacityIncrement()>();
interfaceinvoke v.<org.apache.hc.core.http.nio.CapacityChannel: void update(int)>(v);
return;
}
public final void consume(java.nio.ByteBuffer) throws java.io.IOException
{
org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer v;
java.nio.ByteBuffer v;
v := @this: org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer;
v := @parameter: java.nio.ByteBuffer;
virtualinvoke v.<org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer: void data(java.nio.ByteBuffer,boolean)>(v, 0);
return;
}
public final void streamEnd(java.util.List) throws org.apache.hc.core.http.HttpException, java.io.IOException
{
org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer v;
java.util.List v;
java.nio.ByteBuffer v;
v := @this: org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer;
v := @parameter: java.util.List;
v = <org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer: java.nio.ByteBuffer EMPTY>;
virtualinvoke v.<org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer: void data(java.nio.ByteBuffer,boolean)>(v, 1);
virtualinvoke v.<org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer: void completed()>();
return;
}
static void <clinit>()
{
byte[] v;
java.nio.ByteBuffer v;
v = newarray (byte)[0];
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
<org.apache.hc.core.http.nio.entity.AbstractBinDataConsumer: java.nio.ByteBuffer EMPTY> = v;
return;
}
}