88 packages
humanify
Allows adding human input to data streams in node.js
infinite-sequence-generator
An infinte set of keys that never ends, never repeats, is somewhat human readble and scales logarythmically.
jetlog
Streamet logger with pluggable outputs and stream interface.
rereadable-stream
A simple standards-based stream that can be read again from begining.
scramjet
Lightweight and real-time data functional stream programming framework like event-stream, written in ES6 using async await with multi-threading and typescript support
@scramjet/adapters
This package is part of Scramjet Transform Hub. This module holds the docker adapters utilized by Scramjet Transform Hub
@scramjet/api-client
This package is part of Scramjet Transform Hub. The package provides the API Client for use with Scramjet Transform Hub.
@scramjet/api-server
This package is part of Scramjet Transform Hub. The package provides the domain model for STH and the CLI.
@scramjet/avengers-names-output
@scramjet/big-file-sequence
@scramjet/can-keep-alive
@scramjet/checksum-sequence
@scramjet/cli
This package is part of Scramjet Transform Hub. The package provides a CLI interface to communicate with Scramjet Transform Hub.
scramjet-cli
Command line interface into running scramjet modules
@scramjet/client-utils
This package is part of Scramjet Transform Hub. The package provides the API Client Utils for use with Scramjet Transform Hub.
@scramjet/csv-transform
This sequence performs transformation on received csv chunks
@scramjet/currency-check
@scramjet/delay-out-in-a
@scramjet/delay-out-in-b
@scramjet/durability-preservation
Sequence downloads following files every second: ``` [ "http://some.host.com/durability-test/file2.bin", "http://some.host.com/durability-test/file1.bin", "http://some.host.com/durability-test/file3.bin" ] ```
@scramjet/durability-preservation-event
The sequence gets the file from the address given in the first parameter. The file is downloaded periodically. The time interval is specified in the second parameter (with seconds). After requesting file, the sequence emits an event with response status c
@scramjet/durability-preservation-tcp
Sequence downloads following files every second: ``` [ "https://assets.scramjet.org/scp-store/durability-test/file1.bin", "https://assets.scramjet.org/scp-store/durability-test/file2.bin", "https://assets.scramjet.org/scp-store/durability-test
@scramjet/endless-names-output
@scramjet/event-sequence
@scramjet/event-sequence-2