Fix FFI (#55)

CHANGELOG.md

@@ -12,6 +12,14 @@ Bugfixes:
 
 Other improvements:
 
+## Next
+
+Breaking changes:
+- Correct type signature for `pipeline`
+
+Bugfixes:
+- Fix FFI for `isPaused` and `pause`
+
 ## [v8.0.0](https://github.com/purescript-node/purescript-node-streams/releases/tag/v8.0.0) - 2022-07-19
 
 Breaking changes:

src/Node/Stream.js

@@ -28,9 +28,9 @@ export const readableLengthImpl = (r) => r.readableLength;
 
 export const resumeImpl = (r) => r.resume();
 
-export const pauseImpl = (r) => r.pause;
+export const pauseImpl = (r) => r.pause();
 
-export const isPausedImpl = (r) => r.isPaused;
+export const isPausedImpl = (r) => r.isPaused();
 
 export const pipeImpl = (r, w) => r.pipe(w);
 

src/Node/Stream.purs

@@ -488,10 +488,10 @@ allowHalfOpen d = runEffectFn1 allowHalfOpenImpl d
 
 foreign import allowHalfOpenImpl :: EffectFn1 (Duplex) (Boolean)
 
-pipeline :: forall w r. Readable w -> Array Duplex -> Writable r -> (Error -> Effect Unit) -> Effect Unit
-pipeline src transforms dest cb = runEffectFn4 pipelineImpl src transforms dest cb
+pipeline :: forall w r. Readable w -> Array Duplex -> Writable r -> (Maybe Error -> Effect Unit) -> Effect Unit
+pipeline src transforms dest cb = runEffectFn4 pipelineImpl src transforms dest $ mkEffectFn1 \err -> cb (toMaybe err)
 
-foreign import pipelineImpl :: forall w r. EffectFn4 (Readable w) (Array Duplex) (Writable r) ((Error -> Effect Unit)) (Unit)
+foreign import pipelineImpl :: forall w r. EffectFn4 (Readable w) (Array Duplex) (Writable r) (EffectFn1 (Nullable Error) Unit) (Unit)
 
 readableFromString :: String -> Encoding -> Effect (Readable ())
 readableFromString str enc = runEffectFn2 readableFromStrImpl str (encodingToNode enc)