Node.Stream.Aff.Internal

onceDrain :: forall w. Writable w -> Effect Unit -> Effect (Effect Unit)

Listen for one drain event, call the callback, then remove the event listener.

Returns an effect for removing the event listener before the event is raised.

onceEnd :: forall r. Readable r -> Effect Unit -> Effect (Effect Unit)

Listen for one end event, call the callback, then remove the event listener.

Returns an effect for removing the event listener before the event is raised.

onceClose :: forall s. Stream s -> Effect Unit -> Effect (Effect Unit)

Listen for one close event, call the callback, then remove the event listener.

Returns an effect for removing the event listener before the event is raised.

onceError :: forall r. Stream r -> (Error -> Effect Unit) -> Effect (Effect Unit)

Listen for one error event, call the callback, then remove the event listener.

Returns an effect for removing the event listener before the event is raised.

onceReadable :: forall r. Readable r -> Effect Unit -> Effect (Effect Unit)

Listen for one readable event, call the callback, then remove the event listener.

Returns an effect for removing the event listener before the event is raised.

readable :: forall r. Readable r -> Effect Boolean

The readable.readable property of a stream.

Is true if it is safe to call readable.read(), which means the stream has not been destroyed or emitted 'error' or 'end'.

writable :: forall w. Writable w -> Effect Boolean

push :: forall r. Readable r -> Nullable Buffer -> Effect Boolean

readable.push(chunk[, encoding])

newReadable :: forall r. Effect (Readable r)

new stream.Readable()

newReadableStringUTF8 :: forall r m. MonadEffect m => String -> m (Readable r)

Construct a UTF-8 Readable from a String.

newStreamPassThrough :: forall m. MonadEffect m => m Duplex

“A trivial implementation of a Transform stream that simply passes the input bytes across to the output.”

Class: stream.PassThrough