aboutsummaryrefslogtreecommitdiff
path: root/node_modules/seek-bzip/lib/stream.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/seek-bzip/lib/stream.js')
-rw-r--r--node_modules/seek-bzip/lib/stream.js42
1 files changed, 42 insertions, 0 deletions
diff --git a/node_modules/seek-bzip/lib/stream.js b/node_modules/seek-bzip/lib/stream.js
new file mode 100644
index 0000000..90f6155
--- /dev/null
+++ b/node_modules/seek-bzip/lib/stream.js
@@ -0,0 +1,42 @@
+/* very simple input/output stream interface */
+var Stream = function() {
+};
+
+// input streams //////////////
+/** Returns the next byte, or -1 for EOF. */
+Stream.prototype.readByte = function() {
+ throw new Error("abstract method readByte() not implemented");
+};
+/** Attempts to fill the buffer; returns number of bytes read, or
+ * -1 for EOF. */
+Stream.prototype.read = function(buffer, bufOffset, length) {
+ var bytesRead = 0;
+ while (bytesRead < length) {
+ var c = this.readByte();
+ if (c < 0) { // EOF
+ return (bytesRead===0) ? -1 : bytesRead;
+ }
+ buffer[bufOffset++] = c;
+ bytesRead++;
+ }
+ return bytesRead;
+};
+Stream.prototype.seek = function(new_pos) {
+ throw new Error("abstract method seek() not implemented");
+};
+
+// output streams ///////////
+Stream.prototype.writeByte = function(_byte) {
+ throw new Error("abstract method readByte() not implemented");
+};
+Stream.prototype.write = function(buffer, bufOffset, length) {
+ var i;
+ for (i=0; i<length; i++) {
+ this.writeByte(buffer[bufOffset++]);
+ }
+ return length;
+};
+Stream.prototype.flush = function() {
+};
+
+module.exports = Stream;