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.

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'.

writeStreamClose :: forall w. Writable w -> Effect Unit -> Effect Unit

The writeStream.close([callback]) function.

Accepts a callback that will be executed when the writeStream has closed.