samples: align with new api

adaltas · Feb 21, 2016 · 1803d6e · 1803d6e
1 parent 71d58c1
commit 1803d6e
Show file tree

Hide file tree

Showing 7 changed files with 22 additions and 41 deletions.
diff --git a/samples/api.promise.js b/samples/api.promise.js
@@ -2,7 +2,7 @@
 var each = require('..');
 
 each( [{id: 1}, {id: 2}, {id: 3}] )
-.run( function(element, index, next){
+.call( function(element, index, next){
   console.log('element: ', element, '@', index);
   setTimeout(next, 500);
 })

diff --git a/samples/array_concurrent.js b/samples/array_concurrent.js
@@ -3,16 +3,16 @@ var each = require('..');
 
 each( [{id: 1}, {id: 2}, {id: 3}] )
 .parallel( 4 )
-.on('item', function(element, index, next) {
+.call(function(element, index, next) {
   console.log('element: ', element, '@', index);
   setTimeout(next, 500);
 })
-.on('error', function(err, errors){
+.error(function(err){
   console.log(err.message);
-  errors.forEach(function(error){
+  err.errors.forEach(function(error){
     console.log('  '+error.message);
   });
 })
-.on('end', function(){
+.then(function(){
   console.log('Done');
-});
+});
diff --git a/samples/array_parallel.js b/samples/array_parallel.js
@@ -3,16 +3,16 @@ var each = require('..');
 
 each( [{id: 1}, {id: 2}, {id: 3}] )
 .parallel( true )
-.on('item', function(element, index, next) {
+.call(function(element, index, next) {
   console.log('element: ', element, '@', index);
   setTimeout(next, 500);
 })
-.on('error', function(err, errors){
+.error(function(err){
   console.log(err.message);
-  errors.forEach(function(error){
+  err.errors.forEach(function(error){
     console.log('  '+error.message);
   });
 })
-.on('end', function(){
+.then(function(){
   console.log('Done');
-});
+});
diff --git a/samples/array_sequential.js b/samples/array_sequential.js
@@ -2,13 +2,13 @@
 var each = require('..');
 
 each( [{id: 1}, {id: 2}, {id: 3}] )
-.on('item', function(element, index, next) {
+.call(function(element, index, next) {
   console.log('element: ', element, '@', index);
   setTimeout(next, 500);
 })
-.on('error', function(err) {
+.error(function(err) {
   console.log(err.message);
 })
-.on('end', function() {
+.then(function() {
   console.log('Done');
 });
diff --git a/samples/object_concurrent.js b/samples/object_concurrent.js
@@ -3,17 +3,17 @@ var each = require('..');
 
 each( {id_1: 1, id_2: 2, id_3: 3} )
 .parallel( 2 )
-.on('item', function(key, value, next) {
+.call(function(key, value, next) {
   console.log('key: ', key);
   console.log('value: ', value);
   setTimeout(next, 500);
 })
-.on('error', function(err, errors){
+.error(function(err){
   console.log(err.message);
-  errors.forEach(function(error){
+  err.errors.forEach(function(error){
     console.log('  '+error.message);
   });
 })
-.on('end', function(){
+.then(function(){
   console.log('Done');
-});
+});
diff --git a/samples/object_sequential.js b/samples/object_sequential.js
@@ -2,14 +2,14 @@
 var each = require('..');
 
 each( {id_1: 1, id_2: 2, id_3: 3} )
-.on('item', function(key, value, next) {
+.call(function(key, value, next) {
   console.log('key: ', key);
   console.log('value: ', value);
   setTimeout(next, 500);
 })
-.on('error', function(err) {
+.error(function(err) {
   console.log(err.message);
 })
-.on('end', function() {
+.then(function() {
   console.log('Done');
 });
diff --git a/samples/readable_stream.js b/samples/readable_stream.js