Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

billow

Package Overview
Dependencies
Maintainers
1
Versions
5
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

billow

A stream pipeline based message processing framework

  • 1.4.0
  • latest
  • Source
  • npm
  • Socket score

Version published
Maintainers
1
Created
Source

billow

js-standard-style Build Status Coverage Status

A stream pipeline based message processing framework.

Install

npm install billow

Usage

'use strict'
const { Billow, Flow, Droplet } = require('billow')

let billow = new Billow({ separator: '\r\n' })
let flowOne = new Flow({ events: ['error', 'dropletError'] })
let flowTwo = new Flow({ events: ['error', 'dropletError'] })

flowOne.on('error', console.error).on('dropletError', console.error)
flowTwo.on('error', console.error).on('dropletError', console.error)

flowOne.addDroplets([
  new Droplet({
    handler: async function (chunk, encoding) {
      return await Promise.resolve(`${chunk.toString()}==`)
    }
  }),
  new Droplet({
    handler: function (chunk, encoding) {
      console.log(chunk.toString())
    }
  })
])

flowTwo.addDroplets([
  new Droplet({
    handler: async function (chunk, encoding) {
      return await Promise.resolve(`${chunk.toString()}~~`)
    }
  }),
  new Droplet({
    handler: function (chunk, encoding) {
      console.log(chunk.toString())
    }
  })
])

billow.addFlow(flowOne).addFlow(flowTwo).write('billow!\r\nbillow!\r\n')
// billow!==
// billow!~~
// billow!==
// billow!~~

How it works

Billow's workflow is based on Flow which is the combination of Droplets. Each Droplet is an implementation of Node.js transform stream, in which you can use async / await function to handle the asynchronous data processing logic with happiness. And Flow is the abstact pipeline of those Droplets, so the data transmission in Flow is very fast and heap memory saved. Because Node.js transform stream will buffer the data when there is no downstream, so all data in Flows will be piped to a writable stream which name is blackHole eventually to prevent the potential resident memory leak.


        | =>          flow one       =>       |
        | ( droplet(1) => droplet(2) => ... ) |
        |                                     |
data => | =>          flow two       =>       | => blackHole
        | ( droplet(4) => droplet(3) => ... ) |
        |                                     |
        | =>          other flows    =>       |

API

Class: Billow

new Billow({ separator, highWaterMark })
  • separator Number : The separator to separate the in coming buffer, if separator is set to be null, then billow will pass the buffer directly to the flows, by default it is '\r\n'.
  • highWaterMark Number : If provided, it will be passed to the inside stream.Writable contructor.

return a new instance of Billow.

addFlow(flow)
  • flow Flow : An instance of flow.

Register a new flow to billow.

Class: Flow

new Flow({ events })
  • events Array<String> : The events you want to listen emitted from the droplets of this flow.

return a new instance of Flow.

addDroplets(droplets)
  • droplets Droplet | Array<Droplet> : The droplets you want to add to the flow.

Register new droplets to flow.

Class: Droplet

new Droplet({ handler , highWaterMark})
  • handler async function (chunk, encoding) {} : The handler to process the chunk, the value this function returns will be pass to the next droplet in current flow.
  • highWaterMark Number : If provided, it will be passed to the inside stream.Transform contructor.

return a new instance of Droplet.

FAQs

Package last updated on 23 Apr 2016

Did you know?

Socket

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.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc