cafe-grader-web Files · node_modules/through/test/async.js

cafe-grader-web

Location: cafe-grader-web/node_modules/through/test/async.js

Commit Description:

submission report

Commit Description:

submission report

References:

r790:7ddf708c67bd default

File last commit:

r789:8cd7e8db7e38 default

Show/Diff file:

Action:

            
                    node_modules/through/test/async.js
                
             | 28 lines
             | 629 B
             | application/javascript 
             | JavascriptLexer
             | 
      
            History
        
           Show Full History
         |
          Annotation
         | Raw
         |
              
              Download
              
      var from = require('from')

      var through = require('../')

      var tape = require('tape')

      tape('simple async example', function (t) {

        var n = 0, expected = [1,2,3,4,5], actual = []

        from(expected)

        .pipe(through(function(data) {

          this.pause()

          n ++

          setTimeout(function(){

            console.log('pushing data', data)

            this.push(data)

            this.resume()

          }.bind(this), 300)

        })).pipe(through(function(data) {

          console.log('pushing data second time', data);

          this.push(data)

        })).on('data', function (d) {

          actual.push(d)

        }).on('end', function() {

          t.deepEqual(actual, expected)

          t.end()

        })

      })

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository permissions settings

Sign in to your account

Last Author

				var from = require('from')
				var through = require('../')

				var tape = require('tape')

				tape('simple async example', function (t) {

				var n = 0, expected = [1,2,3,4,5], actual = []
				from(expected)
				.pipe(through(function(data) {
				this.pause()
				n ++
				setTimeout(function(){
				console.log('pushing data', data)
				this.push(data)
				this.resume()
				}.bind(this), 300)
				})).pipe(through(function(data) {
				console.log('pushing data second time', data);
				this.push(data)
				})).on('data', function (d) {
				actual.push(d)
				}).on('end', function() {
				t.deepEqual(actual, expected)
				t.end()
				})

				})