docs

lib/adapter.js

@@ -15,20 +15,16 @@
  * Below is an example of setting up a [client-side]{@tutorial client} adapter for AngularJS $q.
  *
  * ```js
- * var spexLib = require('spex'); // or include client-side spex.js
+ * const spexLib = require('spex'); // or include client-side spex.js
  *
- * var adapter = new spexLib.PromiseAdapter(
- *    function (cb) {
- *        return $q(cb); // creating a new promise;
- *    }, function (data) {
- *        return $q.when(data); // resolving a promise;
- *    }, function (reason) {
- *        return $q.reject(reason); // rejecting a promise;
- *    });
+ * const adapter = new spexLib.PromiseAdapter(
+ *    cb => $q(cb), // creating a new promise;
+ *    data => $q.when(data), // resolving a promise;
+ *    reason => $q.reject(reason) // rejecting a promise;
+ *    );
  *
- * var spex = spexLib(adapter);
+ * const spex = spexLib(adapter);
  * ```
- * Please note that AngularJS 1.4.1 or later no longer requires a promise adapter.
  *
  * @param {Function} create
  * A function that takes a callback parameter and returns a new promise object.

lib/ext/stream/index.js

@@ -10,44 +10,44 @@ const npm = {
  * **Synchronous Stream Processing**
  *
  * ```js
- * var stream = require('spex')(Promise).stream;
- * var fs = require('fs');
+ * const stream = require('spex')(Promise).stream;
+ * const fs = require('fs');
  *
- * var rs = fs.createReadStream('values.txt');
+ * const rs = fs.createReadStream('values.txt');
  *
  * function receiver(index, data, delay) {
  *    console.log('RECEIVED:', index, data, delay);
  * }
  *
  * stream.read(rs, receiver)
- *     .then(function (data) {
+ *     .then(data => {
  *         console.log('DATA:', data);
  *     })
- *     .catch(function (error) {
+ *     .catch(error => {
  *         console.log('ERROR:', error);
  *     });
  * ```
  *
  * **Asynchronous Stream Processing**
  *
  * ```js
- * var stream = require('spex')(Promise).stream;
- * var fs = require('fs');
+ * const stream = require('spex')(Promise).stream;
+ * const fs = require('fs');
  *
- * var rs = fs.createReadStream('values.txt');
+ * const rs = fs.createReadStream('values.txt');
  *
  * function receiver(index, data, delay) {
- *    return new Promise(function (resolve) {
+ *    return new Promise(resolve => {
  *        console.log('RECEIVED:', index, data, delay);
  *        resolve();
  *    });
  * }
  *
  * stream.read(rs, receiver)
- *     .then(function (data) {
+ *     .then(data => {
  *         console.log('DATA:', data);
  *     })
- *     .catch(function (error) {
+ *     .catch(error => {
  *         console.log('ERROR:', error);
  *    });
  * ```

lib/ext/stream/read.js

@@ -129,10 +129,9 @@ function read(stream, receiver, options, config) {
             } else {
                 cache = [];
                 waiting = true;
+                let page;
                 do {
-                    // TODO: var page is defined wrong way here
-                    // eslint-disable-next-line
-                    var page = stream.read(readSize);
+                    page = stream.read(readSize);
                     if (page) {
                         cache.push(page);
                         // istanbul ignore next: requires a unique stream that

lib/index.js

@@ -22,12 +22,12 @@ const npm = {
  * ### usage
  * For any third-party promise library:
  * ```js
- * var promise = require('bluebird');
- * var spex = require('spex')(promise);
+ * const promise = require('bluebird');
+ * const spex = require('spex')(promise);
  * ```
  * For ES6 promises:
  * ```js
- * var spex = require('spex')(Promise);
+ * const spex = require('spex')(Promise);
  * ```
  *
  * @param {Object|Function} promiseLib