💦 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 Stream
s, but acts upon the head of the stream.
It was created in order to help implement small-scale firehoses.
Other applications might include sending alerts via SMS or OSX notifications on breaking news or the mention of particular topics.
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
)
With yarn
:
yarn add monitor-head-stream
With npm
:
npm install --save monitor-head-stream