Security News
Input Validation Vulnerabilities Dominate MITRE's 2024 CWE Top 25 List
MITRE's 2024 CWE Top 25 highlights critical software vulnerabilities like XSS, SQL Injection, and CSRF, reflecting shifts due to a refined ranking methodology.
mux-web-streams
Advanced tools
mux-web-streams
enables you to multiplex and demultiplex (AKA "mux" and "demux") streams. Stream multiplexing combines multiple streams into a single stream, so that they can be sent over one communication channel, such as in a single HTTP response. Stream demultiplexing is the opposite operation – it takes a single stream and splits it into multiple streams.
mux-web-streams
uses WHATWG-standard Web Streams, which work across Browsers, Node, Bun, Deno.
At Transcend, we use mux-web-streams
to stream LLM responses when using langchain on Lamdba functions with Vercel. This allows us to stream responses as they're generated, while also passing other metadata to the client, such as ChainValues.
You can install mux-web-streams
using npm:
npm install mux-web-streams # or `pnpm` or `yarn`
To use mux-web-streams
, import the desired functions from the library:
import { demuxer, muxer } from 'mux-web-streams';
The muxer
function is used to multiplex an array of ReadableStream
s into a single stream.
import { muxer } from 'mux-web-streams';
// Multiplex readable streams into a single stream
const multiplexedReadableStream: ReadableStream<Uint8Array> = muxer([
readableStream0,
readableStream1,
readableStream2,
readableStream3,
readableStream4,
]);
The demuxer
function is used to demultiplex a multiplexed stream back into the original array of ReadableStream
s.
import { demuxer } from 'mux-web-streams';
// Demultiplex the stream and listen for emitted streams
const [
readableStream0,
readableStream1,
readableStream2,
readableStream3,
readableStream4,
] = demuxer(multiplexedReadableStream, 5);
// Use your streams!
readableStream0.pipeTo(/* ... */);
muxer(streams: ReadableStream<SerializableData>[]): ReadableStream<Uint8Array>
Multiplexes an array of ReadableStream
s into a single stream.
streams
: An array of ReadableStream
s to be multiplexed.demuxer(stream: ReadableStream, numberOfStreams: number): ReadableStream<SerializableData>[]
Demultiplexes a single multiplexed ReadableStream
into an array of ReadableStream
s.
stream
: The multiplexed stream from muxer()
.numberOfStreams
: The number of streams passed into muxer()
.SerializableData
The ReadableStream
s passed into muxer()
must emit SerializableData
. This can be a Uint8Array
, or anything that's deserializable from JSON, such as string
, number
, boolean
, null
, or objects and arrays composed of those primitive types.
Here's an example using Langchain on Vercel functions. We want to render the AI chat completion as it comes, while also passing the chain values to the client, allowing the end-user to review the source documents behind the chatbot's answer. The chain values return the source documents that were provided to the LLM chat model using a RAG architecture. A more elaborate example might include error messages and other data.
// app/api/chat/route.ts
import { muxer } from 'mux-web-streams';
export async function POST(request: Request): Promise<Response> {
// Get several ReadableStreams
const chatResponseStream: ReadableStream<string> = createReadableStream();
const chainValuesStream: ReadableStream<ChainValues> = createReadableStream();
// Multiplex the streams into a single stream
const multiplexedStream = muxer([chatResponseStream, chainValuesStream]);
// Stream the multiplexed data
return new Response(multiplexedStream, {
headers: {
'Content-Type': 'text/event-stream',
Connection: 'keep-alive',
'Cache-Control': 'no-cache, no-transform',
},
});
}
// components/chat.tsx
import type { ChainValues } from 'langchain/schema';
import { demuxer } from 'mux-web-streams';
export const Chat = () => {
const [chatResponse, setChatResponse] = useState<string>('');
const [chainValues, setChainValues] = useState<Record<string, any>>({});
const onClick = async () => {
const res = await fetch('/api/chat', {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({ myInput: 0 }),
});
if (!res.body) {
throw new Error('No body');
}
// Demultiplex the multiplexed stream
const [chatResponseStream, chainValuesStream] = demuxer(res.body, 2);
// Write generation to the UI as it comes
chatResponseStream.pipeThrough(new TextDecoderStream()).pipeTo(
new WritableStream({
write(chunk) {
// Update text of the most recently added element (the AI message)
setChatResponse(chatResponse + chunk);
},
}),
);
// Render the chain values when they come
chainValuesStream.pipeTo(
new WritableStream({
write(chunk) {
setChainValues(JSON.parse(chunk));
},
}),
);
};
return (
<div>
<button onClick={onClick}>Get multiplexed stream</button>
<p>Demuxed results:</p>
<ul>
<li>Chat response: {chatResponse}</li>
<li>
Chain values:{' '}
<pre>
<code>{JSON.stringify(chainValues, null, 2)}</code>
</pre>
</li>
</ul>
</div>
);
};
MIT
FAQs
Multiplex and demultiplex web streams.
The npm package mux-web-streams receives a total of 10 weekly downloads. As such, mux-web-streams popularity was classified as not popular.
We found that mux-web-streams demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 1 open source maintainer collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
MITRE's 2024 CWE Top 25 highlights critical software vulnerabilities like XSS, SQL Injection, and CSRF, reflecting shifts due to a refined ranking methodology.
Security News
In this segment of the Risky Business podcast, Feross Aboukhadijeh and Patrick Gray discuss the challenges of tracking malware discovered in open source softare.
Research
Security News
A threat actor's playbook for exploiting the npm ecosystem was exposed on the dark web, detailing how to build a blockchain-powered botnet.