unbuffer

Author: jamesdbrock

spago-dev.dhall

@@ -19,6 +19,7 @@ conf //
   , "node-fs"
   , "console"
   , "partial"
+  , "unsafe-coerce"
   ]
 , packages = packages_dev
 }

src/Node/Stream/Aff.purs

@@ -81,6 +81,7 @@ module Node.Stream.Aff
   , readN_
   , write
   , write_
+  , module Reexport
   )
 
 where
@@ -102,6 +103,7 @@ import Node.Buffer as Buffer
 import Node.Stream (Readable, Writable)
 import Node.Stream as Stream
 import Node.Stream.Aff.Internal (onceDrain, onceEnd, onceError, onceReadable)
+import Node.Stream.Aff.Internal (unbuffer) as Reexport
 
 
 -- | Wait until there is some data available from the stream.

src/Node/Stream/Internal.js

@@ -5,19 +5,32 @@ export function onceReadable(s) {
 }
 
 export function onceEnd(s) {
-	return f => () => {
-		s.once('end', f);
-	};
+  return f => () => {
+    s.once('end', f);
+  };
 }
 
 export function onceDrain(s) {
-	return f => () => {
-		s.once('drain', f);
-	};
+  return f => () => {
+    s.once('drain', f);
+  };
 }
 
 export function onceError(s) {
-	return f => () => {
-		s.once('error', f);
-	};
+  return f => () => {
+    s.once('error', f);
+  };
+}
+
+export function unbuffer(s) {
+  // // https://github.com/nodejs/node/issues/6456
+  // return () => {
+  // 	s && s.isTTY && s._handle && s._handle.setBlocking && s._handle.setBlocking(true);
+  // };
+
+  // https://github.com/nodejs/node/issues/6379#issuecomment-1064044886
+  return () => {
+  	// s && s._handle && s._handle.setBlocking && s._handle.setBlocking(true);
+  	s._handle.setBlocking(true);
+  };
 }

src/Node/Stream/Internal.purs

@@ -3,6 +3,7 @@ module Node.Stream.Aff.Internal
   , onceEnd
   , onceDrain
   , onceError
+  , unbuffer
   )
 where
 
@@ -40,4 +41,15 @@ foreign import onceError
   :: forall r
    . Stream r
   -> (Error -> Effect Unit)
-  -> Effect Unit
+  -> Effect Unit
+
+-- | Issue:
+-- | https://github.com/nodejs/node/issues/6379
+-- |
+-- | Implementation:
+-- | https://github.com/nodejs/node/issues/6456
+foreign import unbuffer
+  :: forall w
+   . Writable w
+  -> Effect Unit
+-- foreign import stdoutUnbuffer :: Effect Unit

test/Main.purs

@@ -26,10 +26,11 @@ import Test.Spec (describe, it)
 import Test.Spec.Assertions (shouldEqual)
 import Test.Spec.Reporter (consoleReporter)
 import Test.Spec.Runner (runSpec)
+import Unsafe.Coerce (unsafeCoerce)
 
 main :: Effect Unit
 main = unsafePartial $ do
-  runAff_ (either (show >>> Console.log) (\_ -> pure unit)) $ runSpec [consoleReporter] do
+  runAff_ (either (unsafeCoerce >>> Console.error) (\_ -> pure unit)) $ runSpec [consoleReporter] do
     describe "Node.Stream.Aff" do
       it "reads 1" do
         infile <- liftEffect $ createReadStream =<< pure <<< flip Array.unsafeIndex 2 =<< argv