1 files changed, 40 insertions, 0 deletions
diff --git a/simple/simple-common/src/test/java/org/simpleframework/common/buffer/queue/ByteQueueStream.java b/simple/simple-common/src/test/java/org/simpleframework/common/buffer/queue/ByteQueueStream.java
new file mode 100644
index 0000000..dbf73e1
--- /dev/null
+++ b/simple/simple-common/src/test/java/org/simpleframework/common/buffer/queue/ByteQueueStream.java
@@ -0,0 +1,40 @@
+package org.simpleframework.common.buffer.queue;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+public class ByteQueueStream extends InputStream {
+   
+   private final ByteQueue queue;
+   
+   public ByteQueueStream(ByteQueue queue) {
+      this.queue = queue;
+   }
+
+   @Override
+   public int read() throws IOException {
+      byte[] array = new byte[1];
+      int count = read(array) ;
+      
+      if(count != -1) {
+         return array[0] & 0xff;
+      }
+      return -1;
+   }
+   
+   public int read(byte[] buffer) throws IOException {
+      return queue.read(buffer, 0, buffer.length);
+   }
+   
+   public int read(byte[] buffer, int off, int size) throws IOException {
+      return queue.read(buffer, off, size);
+   }
+   
+   public int available() throws IOException {
+      return queue.available();
+   }
+   
+   public void close() throws IOException {
+      queue.close();
+   }  
+}