barnard59-base
v2.5.2Linked Data pipelines
18 operations4 sources13 transforms1 sinkMIT licensed43k downloads/mo
Operations
- /dev/nullnulDummy output stream, just like /dev/null.
- BatchbatchGroups incoming items into arrays of the given size.
- CombinecombineCombines multiple streams to a single stream connecting them in the given order.
- ConcatconcatConcatenates the content of the given streams to a single stream.
- Concat (Object)concat/objectConcatenates the content of the given streams to a single stream.
- FilterfilterForwards incoming chunks if they pass the filter function.
- FlattenflattenSeparates incoming arrays into their elements and emits each element as a single chunk.
- For EachforEachCalls a sub pipeline for each incoming chunk.
- GlobglobMatch files using the given pattern and emits each filename as a single chunk.
- LimitlimitLimits the amount of forwarded chunks and discards any chunks after reaching the limit.
- MapmapConverts each chunk using the given function.
- OffsetoffsetDiscards all chunks before the given offset.
- Parse JSONjson/parseConverts each chunk to an object by calling JSON.parse().
- Serialize JSONjson/stringifyConverts each chunk to a JSON string by calling JSON.stringify().
- stdinstdinReads from standard input
- stdoutstdoutWrites the incoming data to stdout and also forwards the data to the stream output.
- Stream valuesstreamValuesCreates a readable stream from the given array.
- To StringtoStringConverts each chunk to a string by calling .toString().