AutoDisposeSingleThreadScheduler.schedule(Runnable, long, TimeUnit) and can be used to cancel the task - best effort.AutoDisposeSingleThreadScheduler.schedule(Runnable, long, TimeUnit)MessageBufferInput.available() to return 0.AutoDisposeSingleThreadScheduler.schedule(Runnable, long, TimeUnit) comleted?InputStream supports mark/reset.ByteArrayInputStream from the runtime library except it's been modified in the following ways:MessageBufferInput so that it uses buf as its buffer array.ByteArrayInputStream that uses buf as its buffer array.ByteArrayOutputStream from the runtime library except it's been modified in the following ways:len bytes of data into an array of bytes from this input stream.count field of this byte array output stream to zero, so that all currently accumulated output in the output stream is discarded.n bytes of input from this input stream.Charset name.len bytes from the specified byte array starting at offset off to this byte array output stream.out.write(buf, 0, count).Copyright © 2016. All Rights Reserved.