style tweaks

Author: davidchambers

await.js

@@ -7,7 +7,7 @@ require('babel/polyfill');
 const S = require('sanctuary');
 
 
-// readFile :: (Object, String) -> Promise String
+//    readFile :: (Object, String) -> Promise Error String
 const readFile = (options, filename) =>
   new Promise((res, rej) => {
     fs.readFile(filename, options, (err, data) => {

coroutines-bluebird.js

@@ -8,17 +8,17 @@ const R = require('ramda');
 const S = require('sanctuary');
 
 
-// readFile :: String -> String -> Promise String
+//    readFile :: String -> String -> Promise Error String
 const readFile = R.curry((encoding, filename) =>
   bluebird.promisify(fs.readFile)(filename, {encoding: encoding})
 );
 
-// readFiles :: String -> [String] -> Promise [String]
+//    readFiles :: String -> [String] -> Promise Error [String]
 const readFiles = R.curry((encoding, filenames) =>
   bluebird.all(R.map(readFile(encoding), filenames))
 );
 
-// walk :: String -> Promise String
+//    walk :: String -> Promise Error String
 const walk = bluebird.coroutine(function*(dir) {
   const pathTo = (filename) => path.join(dir, filename);
   const index = yield readFile('utf8', pathTo('index.txt'));

coroutines-co.js

@@ -8,7 +8,7 @@ const R = require('ramda');
 const S = require('sanctuary');
 
 
-// readFile :: String -> String -> Promise String
+//    readFile :: String -> String -> Promise Error String
 const readFile = R.curry((encoding, filename) =>
   new Promise((res, rej) => {
     fs.readFile(filename, {encoding: encoding}, (err, data) => {
@@ -21,7 +21,7 @@ const readFile = R.curry((encoding, filename) =>
   })
 );
 
-// readFiles :: String -> [String] -> Promise [String]
+//    readFiles :: String -> [String] -> Promise Error [String]
 const readFiles = R.curry((encoding, filenames) =>
   Promise.all(R.map(readFile(encoding), filenames))
 );

kgo.js

@@ -9,11 +9,12 @@ const R = require('ramda');
 const S = require('sanctuary');
 
 
-// join :: String -> String -> String
+//    join :: String -> String -> String
 const join = R.curryN(2, path.join);
 
-// data Text = Buffer | String
-// readFile :: String -> String -> ((Error?, Text?) -> Unit) -> Unit
+//    data Text = Buffer | String
+//    readFile ::
+//      String -> String -> ((Error?, Text?) -> Undefined) -> Undefined
 const readFile = R.curry((encoding, filename, callback) => {
   fs.readFile(filename, {encoding: encoding}, callback);
 });

lazy-either.js

@@ -7,35 +7,36 @@ const LazyEither = require('lazy-either');
 const R = require('ramda');
 const S = require('sanctuary');
 
-// join :: String -> String -> String
+
+//    join :: String -> String -> String
 const join = R.curryN(2, path.join);
 
-// readFile :: String -> String -> LazyEither Error String
+//    readFile :: String -> String -> LazyEither Error String
 const readFile = R.curry((encoding, filename) =>
   new LazyEither(resolve => {
-    fs.readFile(filename, {encoding: encoding}, (err, data) =>
-        resolve(err !== null ? S.Left(err) : S.Right(data)));
+    fs.readFile(
+      filename,
+      {encoding: encoding},
+      (err, data) => resolve(err != null ? S.Left(err) : S.Right(data))
+    );
   }));
 
-// readFiles :: [String] -> LazyEither Error String
-const readFiles = R.traverse(LazyEither.of, readFile('utf8'));
-
-// concatFiles :: String -> LazyEither Error String
+//    concatFiles :: String -> LazyEither Error String
 const concatFiles = dir =>
   S.pipe([readFile('utf8'),
           R.map(S.lines),
           R.map(R.map(join(dir))),
-          R.chain(readFiles),
+          R.chain(R.traverse(LazyEither.of, readFile('utf8'))),
           R.map(R.join(''))],
          join(dir, 'index.txt'))
 
+
 const main = () => {
   concatFiles(process.argv[2]).value(either => {
     if (either.isRight) {
       process.stdout.write(either.value);
       process.exit(0);
-    }
-    else {
+    } else {
       process.stderr.write(String(either.value) + '\n');
       process.exit(1);
     }

promises-ramda.js

@@ -9,16 +9,16 @@ const R = require('ramda');
 const S = require('sanctuary');
 
 
-// join :: String -> String -> String
+//    join :: String -> String -> String
 const join = R.curryN(2, path.join);
 
-// readFile :: Object -> String -> Promise String
+//    readFile :: Object -> String -> Promise Error String
 const readFile = S.flip(Promise.promisify(fs.readFile));
 
-// then :: (a -> b) -> Promise a -> Promise b
+//    then :: (a -> b) -> Promise e a -> Promise e b
 const then = R.invoker(1, 'then');
 
-// concatFiles :: String -> Promise String
+//    concatFiles :: String -> Promise Error String
 const concatFiles = dir =>
   S.pipe([join(R.__, 'index.txt'),
           readFile({encoding: 'utf8'}),

promises.js

@@ -6,7 +6,7 @@ const path = require('path');
 const S = require('sanctuary');
 
 
-// readFile :: (Object, String) -> Promise String
+//    readFile :: (Object, String) -> Promise Error String
 const readFile = (options, filename) =>
   new Promise((res, rej) => {
     fs.readFile(filename, options, (err, data) => {

righto.js

@@ -6,10 +6,11 @@ const path = require('path');
 const righto = require('righto');
 
 
-// readFile :: String -> String -> Righto String
+//    readFile :: String -> String -> Righto String
 const readFile = dir => file =>
   righto(fs.readFile, path.join(dir, file), {encoding: 'utf8'});
 
+
 const main = () => {
   const dir = process.argv[2];
 

tasks.js

@@ -8,11 +8,11 @@ const R = require('ramda');
 const S = require('sanctuary');
 
 
-// join :: String -> String -> String
+//    join :: String -> String -> String
 const join = R.curryN(2, path.join);
 
-// data Text = Buffer | String
-// readFile :: String -> String -> Task Error Text
+//    data Text = Buffer | String
+//    readFile :: String -> String -> Task Error Text
 const readFile = R.curry((encoding, filename) =>
   new Task((rej, res) => {
     fs.readFile(filename, {encoding: encoding}, (err, data) => {
@@ -25,7 +25,7 @@ const readFile = R.curry((encoding, filename) =>
   })
 );
 
-// concatFiles :: String -> Task Error String
+//    concatFiles :: String -> Task Error String
 const concatFiles = dir =>
   S.pipe([readFile('utf8'),               // :: Task Error String
           R.map(S.lines),                 // :: Task Error [String]