Initial commit

Author: paf31

.gitignore

@@ -0,0 +1,5 @@
+/bower_components/
+/node_modules/
+/output/
+/.psci*
+/src/.webpack.js

LICENSE

@@ -0,0 +1,20 @@
+The MIT License (MIT)
+
+Copyright (c) 2015 DICOM Grid, Inc.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+the Software, and to permit persons to whom the Software is furnished to do so,
+subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

bower.json

@@ -0,0 +1,20 @@
+{
+  "name": "purescript-node-streams",
+  "moduleType": [
+    "node"
+  ],
+  "ignore": [
+    "**/.*",
+    "node_modules",
+    "bower_components",
+    "output"
+  ],
+  "devDependencies": {
+    "purescript-console": "^0.1.0"
+  },
+  "dependencies": {
+    "purescript-eff": "~0.1.1",
+    "purescript-node-buffer": "~0.1.0",
+    "purescript-prelude": "~0.1.2"
+  }
+}

docs/Node/Stream.md

@@ -0,0 +1,179 @@
+## Module Node.Stream
+
+This module provides a low-level wrapper for the Node Stream API.
+
+#### `Stream`
+
+``` purescript
+data Stream :: # * -> # ! -> * -> *
+```
+
+A stream.
+
+The type arguments track, in order:
+
+- Whether reading and/or writing from/to the stream are allowed.
+- Effects associated with reading/writing from/to this stream.
+- The type of chunks which will be read from/written to this stream (`String` or `Buffer`).
+
+#### `Read`
+
+``` purescript
+data Read
+```
+
+A phantom type associated with _readable streams_.
+
+#### `Readable`
+
+``` purescript
+type Readable r = Stream (read :: Read | r)
+```
+
+A readable stream.
+
+#### `Write`
+
+``` purescript
+data Write
+```
+
+A phantom type associated with _writable streams_.
+
+#### `Writable`
+
+``` purescript
+type Writable r = Stream (write :: Write | r)
+```
+
+A writable stream.
+
+#### `Duplex`
+
+``` purescript
+type Duplex = Stream (read :: Read, write :: Write)
+```
+
+A duplex (readable _and_ writable stream)
+
+#### `setEncoding`
+
+``` purescript
+setEncoding :: forall w eff. Readable w eff String -> Encoding -> Eff eff Unit
+```
+
+Set the encoding used to read chunks from the stream.
+
+#### `onData`
+
+``` purescript
+onData :: forall w eff a. Readable w eff a -> (a -> Eff eff Unit) -> Eff eff Unit
+```
+
+Listen for `data` events.
+
+#### `onEnd`
+
+``` purescript
+onEnd :: forall w eff a. Readable w eff a -> Eff eff Unit -> Eff eff Unit
+```
+
+Listen for `end` events.
+
+#### `onClose`
+
+``` purescript
+onClose :: forall w eff a. Readable w eff a -> Eff eff Unit -> Eff eff Unit
+```
+
+Listen for `close` events.
+
+#### `onError`
+
+``` purescript
+onError :: forall w eff a. Readable w eff a -> Eff eff Unit -> Eff eff Unit
+```
+
+Listen for `error` events.
+
+#### `resume`
+
+``` purescript
+resume :: forall w eff a. Readable w eff a -> Eff eff Unit
+```
+
+Resume reading from the stream.
+
+#### `pause`
+
+``` purescript
+pause :: forall w eff a. Readable w eff a -> Eff eff Unit
+```
+
+Pause reading from the stream.
+
+#### `isPaused`
+
+``` purescript
+isPaused :: forall w eff a. Readable w eff a -> Eff eff Boolean
+```
+
+Check whether or not a stream is paused for reading.
+
+#### `pipe`
+
+``` purescript
+pipe :: forall r w eff a. Readable w eff a -> Writable r eff a -> Eff eff (Writable r eff a)
+```
+
+Read chunks from a readable stream and write them to a writable stream.
+
+#### `write`
+
+``` purescript
+write :: forall r eff a. Writable r eff String -> a -> Eff eff Unit -> Eff eff Boolean
+```
+
+Write a chunk to a writable stream.
+
+#### `writeString`
+
+``` purescript
+writeString :: forall r eff a. Writable r eff String -> Encoding -> String -> Eff eff Unit -> Eff eff Boolean
+```
+
+Write a string in the specified encoding to a writable stream.
+
+#### `cork`
+
+``` purescript
+cork :: forall r eff a. Writable r eff a -> Eff eff Unit
+```
+
+Force buffering of writes.
+
+#### `uncork`
+
+``` purescript
+uncork :: forall r eff a. Writable r eff a -> Eff eff Unit
+```
+
+Flush buffered data.
+
+#### `setDefaultEncoding`
+
+``` purescript
+setDefaultEncoding :: forall r eff. Writable r eff String -> Encoding -> Eff eff Unit
+```
+
+Set the default encoding used to write chunks to the stream.
+
+#### `end`
+
+``` purescript
+end :: forall r eff a. Writable r eff a -> Eff eff Unit -> Eff eff Unit
+```
+
+End writing data to the stream.
+
+

src/Node/Stream.js

@@ -0,0 +1,129 @@
+"use strict";
+
+// module Node.Stream
+
+exports.setEncodingImpl = function(s) {
+    return function(enc) {
+        return function() {
+            s.setEncoding(enc);
+        };
+    };
+};
+
+exports.onData = function(r) {
+    return function(f) {
+        return function() {
+            s.on('data', function(chunk) {
+                f(chunk)();
+            });
+        };
+    };
+};
+
+exports.onEnd = function(r) {
+    return function(f) {
+        return function() {
+            s.on('end', function() {
+                f();
+            });
+        };
+    };
+};
+
+exports.onError = function(r) {
+    return function(f) {
+        return function() {
+            s.on('error', function() {
+                f();
+            });
+        };
+    };
+};
+
+exports.onClose = function(r) {
+    return function(f) {
+        return function() {
+            s.on('close', function() {
+                f();
+            });
+        };
+    };
+};
+
+exports.resume = function(s) {
+    return function() {
+        s.resume();
+    };
+};
+
+exports.pause = function(s) {
+    return function() {
+        s.pause();
+    };
+};
+
+exports.isPaused = function(s) {
+    return function() {
+        return s.isPaused();
+    };
+};
+
+exports.pipe = function(r) {
+    return function(w) {
+        return function() {
+            return r.pipe(w);
+        };
+    };
+};
+
+exports.write = function(w) {
+    return function(chunk) {
+        return function(done) {
+            return function() {
+                return w.write(chunk, null, done);
+            };
+        };
+    };
+};
+
+exports.writeStringImpl = function(w) {
+    return function(enc) {
+        return function(s) {
+            return function(done) {
+                return function() {
+                    return w.write(s, enc, done);
+                };
+            };
+        };
+    };
+};
+
+exports.cork = function(w) {
+    return function() {
+        return w.cork();
+    };
+};
+
+exports.uncork = function(w) {
+    return function() {
+        return w.uncork();
+    };
+};
+
+exports.setDefaultEncodingImpl = function(w) {
+    return function(enc) {
+        return function() {
+            w.setDefaultEncoding(enc);
+        };
+    };
+};
+
+exports.end = function(w) {
+    return function(done) {
+        return function() {
+            w.end(null, null, function() {
+                f();
+            });
+        };
+    };
+};