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

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. String -> Effect (Readable r)

Construct a Readable from a String.