public interface  org.apache.kafkaesque.common.network.Receive extends java.lang.Object implements java.io.Closeable
{
public abstract java.lang.String source();
public abstract boolean complete();
public abstract long readFrom(java.nio.channels.ScatteringByteChannel) throws java.io.IOException;
public abstract boolean requiredMemoryAmountKnown();
public abstract boolean memoryAllocated();
}