Functional streaming

desc

Stream creation

Functions that create streams

as_reader()

Coerce an object to a readable stream

as_writer()

Coerce an object to a writeable stream

Stream transformation

Functions that manipulate streams

batch_stream()

Batch stream

collect_stream()

Collect stream

filter_stream()

Filter stream

flatten_stream()

Flatten stream

is_readable_stream()

TODOC

is_transform_stream()

TODOC

is_writeable_stream()

TODOC

limit_stream()

Limit stream

map_stream()

Map stream

reduce_stream()

Reduce stream

walk_stream()

Walk stream

Queue strategies

Functions used to create pre-set queue strategies

QueueStrategy

Queue Strategy

byte_size_strategy

Byte size queue strategy

no_backpressure_strategy

No backpressure strategy

object_length_strategy

Object length strategy

Pipes

Pipes that manipulate streams in some way

`%|>%`

Stream pipe

`%T>%`

Tee pipe

Events

Functions that listen to events

on()

On event

once()

Once event

Object-Oriented streaming

desc

ReadableStream

ReadableStream

TransformStream

Transform Stream

WriteableStream

WriteableStream

QueueStrategy

Queue Strategy

EventEmitter

Event Emitter

Misc

desc

Readable Controller

Readable Controller

summary(<ReadableStream>)

These are designed to be reminiscent of the summary produced by connections.

summary(<TransformStream>)

TransformStream summary

summary(<WriteableStream>)

WriteableStream summary

promise_once()

Async once-event

is_readable_stream()

TODOC

is_transform_stream()

TODOC

is_writeable_stream()

TODOC