const stream = require('stream')

let Feed = function (channel) {
  let readable = new stream.Readable({ objectMode: true })
  let news = [
    'aaa',
    'bbb',
    'ccc',
    'ddd',
  ]

  readable._read = () => {
    if (news.length) {
      // console.log('-' + news[0])
      return readable.push(news.shift())
    }
    readable.push(null)
  }

  return readable
}

let feed = new Feed()

/*
feed.on('data', (data) => {
  console.log(data)
})
*/

feed.on('readable', () => {
  const data = feed.read()
  console.log(data)
})

feed.on('close', () => {
  console.log('close.')
})

feed.on('end', () => {
  console.log('done.')
})