barnard59-base v1.1.0

Linked Data pipelines

Operations

In this section you will find the list of all defined operations for this barnard59 package.

Combine

Combines multiple streams to a single stream connecting them in the given order.

Concat

Concatenates the content of the given streams to a single stream.

Concat (Object)

Concatenates the content of the given streams to a single stream.

Filter

Forwards incoming chunks if they pass the filter function.

Flatten

Separates incoming arrays into their elements and emits each element as a single chunk.

For Each

Calls a sub pipeline for each incoming chunk.

Glob

Match files using the given pattern and emits each filename as a single chunk.

Parse JSON

Converts each chunk to an object by calling JSON.parse().

Serialize JSON

Converts each chunk to a JSON string by calling JSON.stringify().

Limit

Limits the amount of forwarded chunks and discards any chunks after reaching the limit.

Map

Converts each chunk using the given function.

/dev/null

Dummy output stream, just like /dev/null.

Offset

Discards all chunks before the given offset.

stdout

Writes the incoming data to stdout and also forwards the data to the stream output.

To String

Converts each chunk to a string by calling .toString().