Server : Apache/2.4.41 (Ubuntu) System : Linux absol.cf 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory :  /usr/local/lib/node_modules/forever/node_modules/event-stream/test/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

var es = require('../')
  , it = require('it-is').style('colour')
  , d = require('ubelt')

function readStream(stream, pauseAt, done) {
  if(!done) done = pauseAt, pauseAt = -1
  var array = [] 
  stream.on('data', function (data) {
    array.push(data)
    if(!--pauseAt )
      stream.pause(), done(null, array)
  })
  stream.on('error', done)
  stream.on('end', function (data) {
    done(null, array)
  })

}

exports ['read an array'] = function (test) {

  var readThis = d.map(3, 6, 100, d.id) //array of multiples of 3 < 100

  var reader = es.readArray(readThis)

  var writer = es.writeArray(function (err, array){
    if(err) throw err //unpossible
    it(array).deepEqual(readThis)
    test.done()     
  })

  reader.pipe(writer)
}

exports ['read an array and pause it.'] = function (test) {

  var readThis = d.map(3, 6, 100, d.id) //array of multiples of 3 < 100

  var reader = es.readArray(readThis)
  
  readStream(reader, 10, function (err, data) {
    if(err) throw err
    it(data).deepEqual([3, 6, 9, 12, 15, 18, 21, 24, 27, 30])
    readStream(reader, 10, function (err, data) {
      it(data).deepEqual([33, 36, 39, 42, 45, 48, 51, 54, 57, 60])
      test.done() 
    })
    reader.resume()
  })

}

exports ['reader is readable, but not writeable'] = function (test) {
  var reader = es.readArray([1])
  it(reader).has({
    readable: true,
    writable: false
  })

  test.done()
}


exports ['read one item per tick'] = function (test) {
  var readThis = d.map(3, 6, 100, d.id) //array of multiples of 3 < 100
  var drains = 0
  var reader = es.readArray(readThis)
  var tickMapper = es.map(function (data,callback) {
    process.nextTick(function () {
      callback(null, data)
    })
    //since tickMapper is returning false
    //pipe should pause the writer until a drain occurs
    return false
  })
  reader.pipe(tickMapper)
  readStream(tickMapper, function (err, array) {
    it(array).deepEqual(readThis)
    it(array.length).deepEqual(readThis.length)
    it(drains).equal(readThis.length)
    test.done()
  })
  tickMapper.on('drain', function () {
    drains ++
  })

}
require('./helper')(module)