public class BytesReceivedStreamSourceConduit
extends org.xnio.conduits.AbstractSourceConduit
implements org.xnio.conduits.StreamSourceConduit
StreamSourceConduit
wrapping that wraps around byte-transferring methods to calculate total
number of bytes transferred leveraging JDK 8 version of LongAdder
(via Infinispan).Constructor and Description |
---|
BytesReceivedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next) |
BytesReceivedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next,
long alreadyReceivedBytes) |
Modifier and Type | Method and Description |
---|---|
static long |
getBytesReceived() |
int |
read(ByteBuffer dst) |
long |
read(ByteBuffer[] dsts,
int offs,
int len) |
long |
transferTo(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target) |
long |
transferTo(long position,
long count,
FileChannel target) |
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, terminateReads, wakeupReads
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public BytesReceivedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next)
public BytesReceivedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next, long alreadyReceivedBytes)
public long transferTo(long position, long count, FileChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
IOException
public int read(ByteBuffer dst) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long read(ByteBuffer[] dsts, int offs, int len) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
IOException
public static long getBytesReceived()
Copyright © 2015 JBoss by Red Hat. All rights reserved.