|
@@ -22,15 +22,12 @@ public class ByteArrayReaderWriter implements ReaderWriter<ByteArray> {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public ByteArray read() throws IOException {
|
|
public ByteArray read() throws IOException {
|
|
- while (in.available() == 0) {
|
|
|
|
- Thread.yield();
|
|
|
|
- }
|
|
|
|
- ByteArrayOutputStream os = new ByteArrayOutputStream();
|
|
|
|
- int oneByte;
|
|
|
|
- while ((oneByte = in.read()) != -1) {
|
|
|
|
- os.write(oneByte);
|
|
|
|
- }
|
|
|
|
- return new ByteArray(os.toByteArray());
|
|
|
|
|
|
+ int availableBytes;
|
|
|
|
+ while ((availableBytes = in.available()) <= 0)
|
|
|
|
+ ;
|
|
|
|
+ byte[] buffer = new byte[availableBytes];
|
|
|
|
+ in.read(buffer);
|
|
|
|
+ return new ByteArray(buffer);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|