❤
npm
Sign UpSign In

monitor-head-stream

0.1.2 • Public • Published

monitor-head-stream Build Status npm version

💦 Monitor the head of a stream

This module polls streams of objects for their latest item(s).

It's sort of like tail -f for Streams, but acts upon the head of the stream.

It was created in order to help implement small-scale firehoses.

Example

import { TimelineStream } from 'scrape-twitter'
import JSONStream from 'JSONStream'
import pump from 'pump'
 
import monitorHeadStream from 'monitor-head-stream'
 
const createStream = () => new TimelineStream('POTUS')
const indexBy = obj => obj.id
const skipWhenPinned = obj => obj.isPinned === true
 
pump(
  monitorHeadStream(createStream, indexBy, skipWhenPinned),
  JSONStream.stringify('[\n', ',\n', '\n]\n'),
  process.stdout
)

Install

With yarn:

yarn add monitor-head-stream

With npm:

npm install --save monitor-head-stream

Readme

Keywords

none

Package Sidebar

Install

npm i monitor-head-stream

Repository

github.com/sebinsua/monitor-head-stream

Homepage

github.com/sebinsua/monitor-head-stream#readme

Weekly Downloads

2

Version

0.1.2

License

MIT

Last publish

Collaborators

  • sebinsua
Try on RunKit
Report malware