@graffy/stream - npm Package Compare versions

Comparing version 0.14.6-beta3 to 0.14.6-beta4

package.json

@@ -5,3 +5,3 @@ {
   "author": "aravind (https://github.com/aravindet)",
-  "version": "0.14.6-beta3",
+  "version": "0.14.6-beta4",
   "main": "index.js",
@@ -8,0 +8,0 @@ "source": "src/index.js",

Readme.md

@@ -40,3 +40,3 @@ # Graffy Stream
 ```js
-const stream = makeStream(push => {
+const stream = makeStream((push) => {
   eventSource.on('event', push);
@@ -55,3 +55,3 @@ return () => eventSource.off('event', push);
 const stream = makeStream((push, end) => {
-  eventSource.on('event', event => push(event));
+  eventSource.on('event', (event) => push(event));
   eventSource.on('end', () => end());
@@ -70,6 +70,6 @@ return () => eventSource.close();
 const stream = makeStream((push, end) => {
-  eventSource.on('event', event => push(event));
+  eventSource.on('event', (event) => push(event));
   eventSource.on('end', () => end());
-  eventSource.on('error', error => end(error));
-  return error => {
+  eventSource.on('error', (error) => end(error));
+  return (error) => {
     if (error) {
@@ -94,4 +94,4 @@ eventSource.closeWithError();
 const stream = makeStream(
-  push => {
-    eventSource.on('event', event => {
+  (push) => {
+    eventSource.on('event', (event) => {
       const wait = push(event);
@@ -98,0 +98,0 @@ if (wait) {

src/makeStream.js

@@ -16,3 +16,3 @@ /*
 
-  const push = value => {
+  const push = (value) => {
     if (complete) return;
@@ -23,3 +23,3 @@ const payload = Promise.resolve({ value, done: false });
     if (payloads.length >= highWatermark) {
-      return new Promise(resolve => {
+      return new Promise((resolve) => {
         drain = resolve;
@@ -30,3 +30,3 @@ });
 
-  const end = error => {
+  const end = (error) => {
     complete = error ? Promise.reject(error) : normalCompletion;
@@ -54,3 +54,3 @@ let resolve;
       if (complete) return complete;
-      return new Promise(resolve => requests.push(resolve));
+      return new Promise((resolve) => requests.push(resolve));
     },
@@ -57,0 +57,0 @@

src/mapStream.js

@@ -13,3 +13,3 @@ import makeStream from './makeStream';
         })
-        .catch(error => end(error));
+        .catch((error) => end(error));
     };
@@ -16,0 +16,0 @@ next();

No alert changes

Improved metrics

Total package byte prevSize

9923

increased by0.24%

No dependency changes