Skip to content
This repository

Wrap in a real stream interface

branch: master

Fetching latest commit…


Cannot retrieve the latest commit at this time

Octocat-spinner-32 examples
Octocat-spinner-32 test
Octocat-spinner-32 .gitignore
Octocat-spinner-32 .travis.yml
Octocat-spinner-32 .zuul.yml
Octocat-spinner-32 LICENCE
Octocat-spinner-32 client.js
Octocat-spinner-32 eiostream.js
Octocat-spinner-32 package.json
Octocat-spinner-32 server.js

build status NPM version Davis Dependency status

simple interface to via node streams

The API is pretty much the same as shoe

Example Client

var engine = require("")

// attach to an server at url '/numbers'
var stream = engine("/numbers")

stream.on('data', function(data) {

Example Server

var http = require("http")
var EngineServer = require("")

// engines need to attach to server instances (see below)
var server = http.createServer(...)

var engine = EngineServer(function(stream) {
    // send back some numbers, you know...for fun
    var iv = setInterval(function () {
        stream.write(String(Math.floor(Math.random() * 2)))
    }, 250)

    stream.once("end", function () {

    stream.pipe(process.stdout, { end : false })

// expose the engine instance at this url
engine.attach(server, "/numbers")

server.listen(8080, function() {
    console.log("Listening on port 8080")


npm install


  • Raynos
  • shtylman
  • juliangruber
  • hij1nx

Licence MIT

Something went wrong with that request. Please try again.