Skip to content

Commit

Permalink
Set indentation as 2 spaces
Browse files Browse the repository at this point in the history
  • Loading branch information
@wdavidw
wdavidw committed Nov 12, 2012
1 parent 8e94fec commit 563268d
Show file tree
Hide file tree
Showing 13 changed files with 696 additions and 696 deletions.
86 changes: 43 additions & 43 deletions readme.md
View file
Expand Up @@ -39,15 +39,15 @@ The following code traverse an array in `sequential` mode.
var each = require('each');
each( [{id: 1}, {id: 2}, {id: 3}] )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('both', function(err) {
if(err){
console.log(err.message);
}else{
console.log('Done');
}
if(err){
console.log(err.message);
}else{
console.log('Done');
}
});
```

Expand All @@ -57,14 +57,14 @@ Or alternatively using the `error` and `end` events:
var each = require('each');
each( [{id: 1}, {id: 2}, {id: 3}] )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('error', function(err) {
console.log(err.message);
console.log(err.message);
})
.on('end', function() {
console.log('Done');
console.log('Done');
});
```

Expand Down Expand Up @@ -155,14 +155,14 @@ var each = require('each');
each( [{id: 1}, {id: 2}, {id: 3}] )
.parallel( true )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('error', function(err, errors){
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
})
.on('end', function(){
console.log('Done');
Expand All @@ -176,17 +176,17 @@ var each = require('each');
each( [{id: 1}, {id: 2}, {id: 3}] )
.parallel( 4 )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('error', function(err, errors){
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
})
.on('end', function(){
console.log('Done');
console.log('Done');
});
```

Expand All @@ -199,15 +199,15 @@ In `sequential` mode:
var each = require('each');
each( {id_1: 1, id_2: 2, id_3: 3} )
.on('item', function(next, key, value) {
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
})
.on('error', function(err) {
console.log(err.message);
console.log(err.message);
})
.on('end', function() {
console.log('Done');
console.log('Done');
});
```

Expand All @@ -218,18 +218,18 @@ var each = require('each');
each( {id_1: 1, id_2: 2, id_3: 3} )
.parallel( 2 )
.on('item', function(next, key, value) {
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
})
.on('error', function(err, errors){
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
})
.on('end', function(){
console.log('Done');
console.log('Done');
});
```

Expand All @@ -248,17 +248,17 @@ var each = require('each');
var eacher = each( {id_1: 1, id_2: 2, id_3: 3} )
.parallel(2)
.on('item', function(next, key, value) {
setTimeout(function(){
eacher.emit('data', key + ',' + value + '\n');
next();
}, 100);
setTimeout(function(){
eacher.emit('data', key + ',' + value + '\n');
next();
}, 100);
})
.on('end', function(){
console.log('Done');
console.log('Done');
});

eacher.pipe(
fs.createWriteStream(__dirname + '/out.csv', { flags: 'w' })
fs.createWriteStream(__dirname + '/out.csv', { flags: 'w' })
);
```

Expand Down
14 changes: 7 additions & 7 deletions samples/array_concurrent.js
View file
Expand Up @@ -4,15 +4,15 @@ var each = require('each');
each( [{id: 1}, {id: 2}, {id: 3}] )
.parallel( 4 )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('error', function(err, errors){
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
})
.on('end', function(){
console.log('Done');
console.log('Done');
});
14 changes: 7 additions & 7 deletions samples/array_parallel.js
View file
Expand Up @@ -4,15 +4,15 @@ var each = require('each');
each( [{id: 1}, {id: 2}, {id: 3}] )
.parallel( true )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('error', function(err, errors){
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
})
.on('end', function(){
console.log('Done');
console.log('Done');
});
8 changes: 4 additions & 4 deletions samples/array_sequential.js
View file
Expand Up @@ -3,12 +3,12 @@ var each = require('each');

each( [{id: 1}, {id: 2}, {id: 3}] )
.on('item', function(next, element, index) {
console.log('element: ', element, '@', index);
setTimeout(next, 500);
console.log('element: ', element, '@', index);
setTimeout(next, 500);
})
.on('error', function(err) {
console.log(err.message);
console.log(err.message);
})
.on('end', function() {
console.log('Done');
console.log('Done');
});
16 changes: 8 additions & 8 deletions samples/object_concurrent.js
View file
Expand Up @@ -4,16 +4,16 @@ var each = require('each');
each( {id_1: 1, id_2: 2, id_3: 3} )
.parallel( 2 )
.on('item', function(next, key, value) {
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
})
.on('error', function(err, errors){
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
console.log(err.message);
errors.forEach(function(error){
console.log(' '+error.message);
});
})
.on('end', function(){
console.log('Done');
console.log('Done');
});
10 changes: 5 additions & 5 deletions samples/object_sequential.js
View file
Expand Up @@ -3,13 +3,13 @@ var each = require('each');

each( {id_1: 1, id_2: 2, id_3: 3} )
.on('item', function(next, key, value) {
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
console.log('key: ', key);
console.log('value: ', value);
setTimeout(next, 500);
})
.on('error', function(err) {
console.log(err.message);
console.log(err.message);
})
.on('end', function() {
console.log('Done');
console.log('Done');
});
12 changes: 6 additions & 6 deletions samples/readable_stream.js
View file
Expand Up @@ -5,15 +5,15 @@ var each = require('each');
var eacher = each( {id_1: 1, id_2: 2, id_3: 3} )
.parallel(2)
.on('item', function(next, key, value) {
setTimeout(function(){
eacher.emit('data', key + ',' + value + '\n');
next();
}, 100);
setTimeout(function(){
eacher.emit('data', key + ',' + value + '\n');
next();
}, 100);
})
.on('end', function(){
console.log('Done');
console.log('Done');
});

eacher.pipe(
fs.createWriteStream(__dirname + '/out.csv', { flags: 'w' })
fs.createWriteStream(__dirname + '/out.csv', { flags: 'w' })
);

0 comments on commit 563268d

Please sign in to comment.