clock-stream

0.1.0 • Public • Published

clock-stream

Build Status

A duplex stream that holds onto data until it receives a "pulse." Perfect for rationing pipes on a schedule.

Example

var CS = require('clock-stream')
 
var stream = new CS()
stream.write(new Buffer([1,2,3,4]))
stream.on('readable', function() {
  console.log(stream.read()) //<Buffer 01 02 03 04>, when it gets called
})
 
//Some other stuff
 
stream.pulse() //Will fire readable
 
var threeAtATime = new CS(3)
threeAtATime.write(new Buffer([1,2,3,4]))
threeAtATime.on('readable', function() {
  console.log(stream.read())
})
 
threeAtATime.pulse() //<Buffer 01 02 03>
threeAtATime.pulse() //<Buffer 04>
 
//Pulse is meant to be used in conjunction with EventEmitter#on
//midi-clock, for instance, can be used for metronome-esque functionality
var MidiClock = require('midi-clock')
var clock = MidiClock()
clock.on('position', threeAtATime.pulse)

API

In addition to the normal duplex stream methods, clock-stream offers:

var CS = require('clock-stream')

Main class for clock-stream

var stream = new CS([pulsesize])

Create a new stream, optionally specifying how many bytes to feed on each pulse

stream.pulse()

Feed the previously specified number of bytes through the stream, or all currently queued data if no size was specified.

See also

Substack's Stream Handbook

Official Stream API docs

Official Buffer API docs

License

MIT

Readme

Keywords

none

Package Sidebar

Install

npm i clock-stream

Weekly Downloads

0

Version

0.1.0

License

MIT

Last publish

Collaborators

  • harrisonm