express-stream
Advanced tools
Response streaming middleware for Express 4.
express-stream exposes two middleware functions.
stream.pipe() is the least opinionated BigPipe implementation around and is ideal for client-side renderingstream.stream() is ideal for server-side renderingBoth methods allow you to get content in front of your users as fast as possible by taking forms of latency that generally occur sequentially and making them occur in parallel.
//Requires
var express = require('express');
var ejs = require('ejs');
var stream = require('express-stream');
var superagent = require('superagent');
//App setup
var app = express();
app.set('views', './views');
app.set('view engine', 'ejs');
//Add the middleware to the desired routes
app.get('/', stream.pipe(), function (req, res) {
res.stream('landing'); //Stream the landing page
superagent
.get(uri)
.end(function (err, response){
res.stream('landing-data', {response.body.data}); //Stream data to populate the landing page
res.close();
}
);
});
This example would immediately stream 'landing' to the browser while the superagent call fatches the dynamic parts of the page. As soon as the superagent call resolves, it is streamed within a self-executing JavaScript block from which it injects some data into the already-rendered view.
//Requires
var express = require('express');
var ejs = require('ejs');
var stream = require('express-stream');
//App setup
var app = express();
app.set('views', './views');
app.set('view engine', 'ejs');
//App-wide streaming setup
stream.useAllAutoTags(true);
stream.streamBefore('pre-body-view');
stream.streamAfter('post-body-view');
//Add the middleware to the desired routes
app.get('/', stream.stream(), function (req, res) {
res.render('landing'); //This route will now stream
});
This example streams the pre-body-layout view as soon as the stream.stream() middleware is run, and then landing and post-body-layout as soon as res.render() is called.
Because express-stream's two middleware functions patch express's res object differently, the API section is divided into two portions--one for each middleware function. Any functions you see within a section are only applicable when used with the middleware from the same portion of the API. stream.pipe()'s API is simpler so it's in a table. stream.stream()'s API is more complex so it's written out with examples.
| Function | Scope | Description | Arguments |
|---|---|---|---|---|
| stream.pipe() | middleware | This middleware function is written for client-side rendering. It can be used as a loose BigPipe implementation. | N/A |
|res.stream(view, options, callback) | res | When you use .pipe(), this funciton is added to the res object. It is the same as res.render() except that it does not close the HTTP connection. | Same as express |
| res.pipe(output, encoding) | res | Send a string of JavaScrpit to the client | Output: JavaScript output as a string Encoding: defaults to 'UTF-8' |
| res.close(output, encoding) | res | Same as res.pipe(), but closes the connection when finished. | Same as res.pipe() |
| stream.wrapJavascript(val) | stream | Whether to wrap all res.pipe() and res.close() output with '' | val: boolean stating whether to use this feature, defaults to false |
App-wide API Call
Set an app-wide options object to be merged with the options param passed to all res.render() and res.stream() calls.
App-wide API Call
Set an app-wide view, or array of views, to stream as soon as the stream.stream() middleware is run. It's recommended that the views passed to .streamBefore() be used to open the <html> and <head> tags and list site-wide dependencies.
If view is an array, all other passed params will be ignored.
options paramcallback paramWith view as a string
stream.streamBefore('global-head', {custom: data});
With view as an array of strings
stream.streamBefore(['global-head-one', 'global-head-two']);
With view as an array of objects
var globalHeadList = [
{view: 'global-head-one', options: {custom: data}},
{view: 'global-head-two'}
]
stream.streamBefore(globalHeadList);
App-wide API Call
Set an app-wide view, or array of views, to stream as soon as the res.render() call completes. It's recommended that the views passed to .streamAfter() be used to close the <body> and <html> tags.
If view is an array, all other passed params will be ignored.
options paramcallback paramWith view as a string
stream.streamAfter('global-footer', {custom: data});
With view as an array of strings
stream.streamAfter(['global-footer-one', 'global-footer-two']);
With view as an array of objects
var globalHeadList = [
{view: 'global-footer-one', options: {custom: data}},
{view: 'global-footer-two'}
]
stream.streamAfter(globalHeadList);
App-wide API Call
If view is true, this will simply stream a <!doctype html><html><head> string to the client. If view is a string, this will stream the associated view with optional options and callback.
options paramcallback paramApp-wide API Call
If view is true, this will simply stream a </head><body> string to the client. If view is a string, this will stream the associated view with optional options and callback.
options paramcallback paramApp-wide API Call
If view is true, this will simply stream a </body></html> string to the client. If view is a string, this will stream the associated view with optional options and callback.
options paramcallback paramApp-wide API Call
A convenience method to set the same boolean value for openHtmlOpenHead, closeHeadOpenBody, and closeBodyCloseHtml in a single call.
Middleware-only API Call
Set an optional route-specific view, or list of views, to be rendered after the .streamBefore() array and before any res.stream()/res.render() views. It's recommended that your .streamBefore() views not close the <head> tag so that route-specific blocking dependencies can be injected into the <head> here.
If headView is an array, all other passed params will be ignored.
options paramcallback paramWith headView as a string
app.get('/stream-route', stream.stream('render-blocking-assets', {custom: data}), function (req, res){
res.render('stream-body');
});
With headView as an array of strings
app.get('/stream-route', stream.stream(['blocking-one', 'blocking-two']), function (req, res){
res.render('stream-body');
});
With headView as an array of objects
var blockingList = [
{view: 'blocking-one', options: {custom: data}},
{view: 'blocking-two'}
]
app.get('/stream-route', stream.stream(blockingList), function (req, res){
res.render('stream-body');
});
Route-specific API Call
Compiles and streams a view, then compiles and streams the views set by .streamAfter(), then closes the connection.
express's res.render() callRoute-specific API Call
Compiles and streams a view just like res.render(), but does not trigger the .streamAfter() array and does not close the connection.
express's res.render() callUsage examples are coming. In the mean time, see this demo app.
FAQs
Response streaming middleware for Express 4.
The npm package express-stream receives a total of 465 weekly downloads. As such, express-stream popularity was classified as not popular.
We found that express-stream 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
Deno 2.2 enhances Node.js compatibility, improves dependency management, adds OpenTelemetry support, and expands linting and task automation for developers.
Security News
React's CRA deprecation announcement sparked community criticism over framework recommendations, leading to quick updates acknowledging build tools like Vite as valid alternatives.
Security News
Ransomware payment rates hit an all-time low in 2024 as law enforcement crackdowns, stronger defenses, and shifting policies make attacks riskier and less profitable.