async-mutex-stream

This package is a TypeScript library for handling asynchronous streams with mutex locking and piping capabilities.

Installation

1npm install async-mutex-stream
2# or
3pnpm add async-mutex-stream

Dependencies

This package requires the following dependencies:

• async-mutex

Features

• Mutex-based synchronization for stream operations
• Support for async generators
• Piping between streams
• Error handling and state management
• Strict type checking
• Stream multicasting

Basic Usage

Simple Stream

Create a basic stream that processes string data:

1import { AsyncMutexStream } from 'async-mutex-stream';
2
3const stream = new AsyncMutexStream({
4	start: async () => {
5		// Optional initialization
6		console.log('Stream started');
7	},
8	write: async (data: string) => {
9		// Process the data
10		console.log(`Processing: ${data}`);
11	},
12	end: async () => {
13		// Optional cleanup
14		console.log('Stream ended');
15	},
16});
17// Use the stream
18await stream.write('Hello');
19await stream.write('World');
20await stream.end();

License

MIT License