Socket
Book a DemoInstallSign in
Socket
s

stoq

npm

Packages

Current Co-maintainers

Former Co-maintainers

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