Security News
NVD Backlog Tops 20,000 CVEs Awaiting Analysis as NIST Prepares System Updates
NVD’s backlog surpasses 20,000 CVEs as analysis slows and NIST announces new system updates to address ongoing delays.
react-streaming
Advanced tools
react-streaming
React 18 Streaming. Full-fledged & Easy.
Follow: Twitter > @brillout
Chat: Discord > Vikereact-streaming
Contents
Features (for React users):
<Suspense>
for SSR apps.conservative
or google-speed
.useAsync()
hook.Features (for library authors):
useSsrData()
: Define isomorphic data.injectToStream()
: Inject chunks to the stream.Easy:
import { renderToStream } from 'react-streaming/server'
const {
pipe, // Node.js (Vercel, AWS EC2, ...)
readable // Edge (Coudflare Workers, Netlify Edge, Vercel Edge, ...)
} = await renderToStream(<Page />)
React 18's new SSR streaming architecture unlocks many capabilities:
getServerSideProps()
nor vite-plugin-ssr
's onBeforeRender()
.)The problem: The current React 18 Streaming architecture is low-level and its ergonomics are cumbersome. (E.g. there is no standard way for library authors to take advantage of the new streaming architecture.)
The solution: react-streaming
.
Install
npm install react-streaming
Server-side
import { renderToStream } from 'react-streaming/server'
const {
pipe, // Defined if running in Node.js, otherwise `null`
readable // Defined if running on the Edge (.e.g. Coudflare Workers), otherwise `null`
} = await renderToStream(<Page />)
Client-side
import { ReactStreaming } from 'react-streaming/client'
// Wrap your root component `<Page>` (aka `<App>`) with `<ReactStreaming>`
const page = (
<ReactStreaming>
<Page />
</ReactStreaming>
)
const options = {
// ...
}
await renderToStream(<Page />, options)
options.disable?: boolean
: Disable streaming.
<Page>
is still rendered to a stream, but the promiseconst promise = renderToStream()
resolves only after the stream has finished. (This effectively disables streaming from a user perspective, while unlocking React 18 Streaming capabilities such as SSR<Supsense>
.)
options.seoStrategy?: 'conservative' | 'google-speed'
conservative
(default): Disable streaming if the HTTP request originates from a bot. (Ensuring bots to always see the whole HTML.)
google-speed
: Don't disable streaming for the Google Bot.
Custom SEO strategy: use options.disable
. For example:
// Always stream, even for bots:
const disable = false
// Disable streaming for bots, except for the Google Bot and some other bot:
const disable =
isBot(userAgent) &&
!['googlebot', 'some-other-bot'].some(n => userAgent.toLowerCase().includes(n))
await renderToStream(<Page />, { disable })
options.userAgent?: string
: The HTTP User-Agent request header. (Needed for options.seoStrategy
.)
options.webStream?: boolean
: Use Web Streams instead of Node.js Streams in Node.js. (Node.js 18 released Web Streams support.)
options.onBoundaryError?: (err: unknown) => void
: Called when a <Suspense>
boundary fails. See Error Handling.
const { streamEnd } = await renderToStream(<Page />)
// ✅ Page Shell succesfully rendered.
const success: boolean = await streamEnd
// Stream ended.
if (success) {
// ✅ <Page> succesfully rendered
} else {
// ❌ A <Suspense> boundary failed.
}
Note that streamEnd
never rejects.
⚠️ Read Error Handling before using
streamEnd
. In particular, do not usesuccess
to change the behavior of your app/stream (because React automatically takes care of gracefully handling<Suspense>
failures).
The promise await renderToStream()
resolves after the page shell is rendered. This means that if an error occurs while rendering the page shell, then the promise rejects with that error.
:book: The page shell is the set of all components before
<Suspense>
boundaries.
try {
await renderToStream(<Page />)
// ✅ Page shell succesfully rendered and is ready in the stream buffer.
} catch(err) {
// ❌ Something went wrong while rendering the page shell.
}
The stream returned by await renderToStream()
doesn't emit errors.
:book: If an error occurs during the stream, then that means that a
<Suspense>
boundary failed. Instead of emiting a stream error, React swallows the error on the server-side and retries to resolve the<Suspense>
boundary on the client-side. If the<Suspense>
fails again on the client-side, then the client-side throws the error.This means that errros occuring during the stream are handled by React and there is nothing for you to do on the server-side. That said, you may want to gracefully handle the error on the client-side e.g. with
react-error-boundary
.You can use
options.onBoundaryError()
for error tracking purposes.
useAsync()
import { useAsync } from 'react-streaming'
function StarWarsMovies() {
return (
<div>
<p>List of Star Wars movies:</p>
<Suspense fallback={<p>Loading...</p>}>
<MovieList />
</Suspense>
</div>
)
}
// This component is isomorphic: it works on both the client-side and server-side.
// The data fetched while SSR is automatically passed and re-used on the client for hydration.
function MovieList() {
const movies = useAsync(async () => {
const response = await fetch('https://star-wars.brillout.com/api/films.json')
return response.json()
})
return (
<ul>
{movies.forEach((movie) => (
<li>
{movie.title} ({movie.release_date})
</li>
))}
</ul>
)
}
react-streaming
enables you to suspend React rendering and await something to happen. (Usually data fetching.)
The novelty here is that it's isomorphic:
You have the choice between three methods:
useAsync()
: Highest-level & easiest.useSsrData()
: High-level & easy.injectToStream()
: Low-level and highly flexible (both useAsync()
and useSsrData()
are based on it). Easy & recommended for injecting script and style tags. Complex for data fetching (if possible, use useSsrData()
or useAsync()
instead).useAsync()
For how to use useAsync()
, see example above.
useSsrData()
import { useSsrData } from 'react-streaming'
function SomeComponent() {
const key = 'some-unique-key'
const someAsyncFunc = async function () {
const value = 'someData'
return value
}
// `useSsrData()` suspends rendering until the promise returned by `someAsyncFunc()` resolves.
const value = useSsrData(key, someAsyncFunc)
assert(value === 'someData')
}
If <SomeComponent>
is rendered only on the client-side, then useSsrData()
is essentially a
cache that never invalidates. (If you want to re-run someAsyncFunc()
, then change the key.)
If <SomeComponent>
is rendered on the server-side (SSR), it injects the
resolved value into the stream and the client-side picks up the injected value. (So that the
client-side doesn't call someAsyncFunc()
but, instead, re-uses the value resolved on
the server-side.)
This is for example how useAsync()
is implemented:
import { useId } from 'react'
import { useSsrData } from 'react-streaming'
function useAsync(asyncFn) {
const id = useId()
return useSsrData(id, asyncFn)
}
injectToStream()
injectToStream(htmlChunk: string)
allows you to inject strings to the current stream.
There are two ways to access injectToStream()
:
renderToStream()
:
import { renderToStream } from 'react-streaming/server'
const { injectToStream } = await renderToStream(<Page />)
useStream()
:
import { useStream } from 'react-streaming'
function SomeComponent() {
const stream = useStream()
if (stream === null) {
// No stream available. This is the case:
// - On the client-side.
// - When `option.disable === true`.
// - When react-streaming is not installed.
}
const { injectToStream } = stream
}
Usage examples:
// Inject JavaScript (e.g. for progressive hydration)
injectToStream('<script type="module" src="/main.js"></script>')
// Inject CSS (e.g. for CSS-in-JS)
injectToStream('<styles>.some-component { color: blue }</styles>')
// Pass data to client
injectToStream(`<script type="application/json">${JSON.stringify(someData)}</script>`)
For a full example of using injectToStream()
, have a look at useSsrData()
's implementation.
FAQs
React 18 Streaming. Full-fledged & Easy.
The npm package react-streaming receives a total of 5,033 weekly downloads. As such, react-streaming popularity was classified as popular.
We found that react-streaming demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 0 open source maintainers 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
NVD’s backlog surpasses 20,000 CVEs as analysis slows and NIST announces new system updates to address ongoing delays.
Security News
Research
A malicious npm package disguised as a WhatsApp client is exploiting authentication flows with a remote kill switch to exfiltrate data and destroy files.
Security News
PyPI now supports digital attestations, enhancing security and trust by allowing package maintainers to verify the authenticity of Python packages.