1 files changed, 58 insertions, 0 deletions
diff --git a/examples/scala-js/javalib/src/main/scala/java/io/ByteArrayInputStream.scala b/examples/scala-js/javalib/src/main/scala/java/io/ByteArrayInputStream.scala
new file mode 100644
index 0000000..697e07b
--- /dev/null
+++ b/examples/scala-js/javalib/src/main/scala/java/io/ByteArrayInputStream.scala
@@ -0,0 +1,58 @@
+package java.io
+
+class ByteArrayInputStream(
+    protected val buf: Array[Byte],
+    offset: Int, length: Int) extends InputStream {
+
+  protected val count: Int = offset + length
+  protected var mark: Int = offset
+  protected var pos: Int = offset
+
+  def this(buf: Array[Byte]) = this(buf, 0, buf.length)
+
+  override def read(): Int = {
+    if (pos >= count)
+      -1
+    else {
+      val res = buf(pos) & 0xFF // convert to unsigned int
+      pos += 1
+      res
+    }
+  }
+
+  override def read(b: Array[Byte], off: Int, reqLen: Int): Int = {
+    if (off < 0 || reqLen < 0 || reqLen > b.length - off)
+      throw new IndexOutOfBoundsException
+
+    val len = Math.min(reqLen, count - pos)
+
+    if (reqLen == 0)
+      0  // 0 requested, 0 returned
+    else if (len == 0)
+      -1 // nothing to read at all
+    else {
+      System.arraycopy(buf, pos, b, off, len)
+      pos += len
+      len
+    }
+  }
+
+  override def skip(n: Long): Long = {
+    val k = Math.max(0, Math.min(n, count - pos))
+    pos += k.toInt
+    k.toLong
+  }
+
+  override def available(): Int = count - pos
+
+  override def markSupported(): Boolean = true
+
+  override def mark(readlimit: Int): Unit =
+    mark = pos
+
+  override def reset(): Unit =
+    pos = mark
+
+  override def close(): Unit = ()
+
+}