Reconnect a tcp stream when it goes down.
TCP Stream Utility Package for Node.js inspired by Rust's Tokio
copy files over a multiplexed tcp stream
TCP stream framer for Node.JS
TCP channel adapter for server-reactor — packs raw TCP stream into message-based ChannelPort with framing protocol
Client For the Pachube TCP Stream API
Auto-switching (tcp/stream vs udp/datagram) unix domain sockets wrapped in a Node stream
SSH library for Dev Tunnels
An HTTP/1.1 client, written from scratch for Node.js
This library provides a handy set of utility functions for manipulating binary values- such as those ascertained from a Buffer, or a TCP stream. These functions can be split into two categories: 1) Type validity checking 2) Type conversion
Node.js Streams, a user-land copy of the stream library from Node.js
Check if something is a Node.js stream
A simple Node.js module to check if a TCP port is already bound.
Get a stream as a string, Buffer, ArrayBuffer or array
tar-stream is a streaming tar parser and generator and nothing else. It operates purely using streams which means you can easily extract/parse tarballs without ever hitting the file system.
Toggle the CLI cursor
destroy a stream if possible
Call a callback when a readable/writable/duplex stream has completed or failed.
Logstash TCP plugin for Bunyan
Muxing Streams to get through one TCP Connection
ISO-on-TCP Protocol implementation
Get and validate the raw body of a readable stream.
A streaming way to send data to a Node.js Worker Thread
A stream that emits multiple other streams one after another.
std::net::TcpStream on steroids
A comprehensive JSON-RPC 2.0 implementation with multiple transport layers and advanced features
Enumerated types implementing std::fmt::Display for sending RESP messages to redis.
A comprehensive JSON-RPC 2.0 implementation with multiple transport layers and advanced features
Snapcast client library — embeddable synchronized multiroom audio
Snapcast binary protocol implementation
Snapcast server library — embeddable synchronized multiroom audio server
OMG CORBA 3.3 Part 2 §14 + §15.7 + §15.9 — voller IIOP-TCP-Transport-Stack: ProfileBody (alle 4 Versionen 1.0-1.3 inkl. TaggedComponents), Connection / Connector / Acceptor mit thread-safer Connection-Reuse, Bidirectional-GIOP. no_std + alloc.
Safe async network functions - ARCHIVED: Code moved to `safina` crate.
Sans-I/O NMEA 0183 envelope parser: checksum, framing, TAG block recognition. Foundation for the marlin suite.
Code generation CLI tool for ash-rpc JSON-RPC implementations
Stateful JSON-RPC handlers with shared context support for ash-rpc
Simple Ruby client library for pachube TCP streaming API. Uses EventMachine for connection handling.JSON format only.
Ikura is a minimal Turbo Stream implementation built from scratch using Ruby Wasm and Ruby's built-in TCPServer — no Rails, no frontend framework, no external runtime dependencies. Click anywhere on the gunkan-maki sushi in the browser to place ikura (salmon roe); click events run in Ruby via WebAssembly and DOM updates arrive as Turbo Streams.
A BinData-powered intercepting proxy for arbitrary TCP streams
kcar features an HTTP parser that will convert a bytestream into a 3-element array suitable for use as a Rack response. It is IO interface agnostic, so it may be used with HTTP streams over Unix domain sockets, regular files, FIFOs, StringIOs as well as traditional TCP sockets.
Pure Ruby implementation of nanomsg's Scalability Protocols (SP) on top of async + io-stream. Per-socket HWM, opportunistic batching, wire-compatible with libnng over inproc/ipc/tcp.
Pure Ruby implementation of MQTT — client and broker in one gem — built on async, io-stream, and protocol-mqtt. Fiber-first, pluggable transports (tcp, tls, ws, ipc), pluggable persistence (in-memory, PStore).
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.