Add, test/{end,start}.js; Update, lib/index.js

README.md

@@ -225,6 +225,31 @@ var checkCache = stewardess(
 .bind();
 ```
 
+### Call `next('restart')` to restart the chain
+
+```javascript
+stewardess(
+  function first(options, next) {
+    return next(options.idex > 10 ? 'skip' : null);
+  },
+  function second(options, next) {
+    options.arr.push(idex);
+    return next();
+  },
+  function third(options, next) {
+    return next(options.idex > 10 ? null : 'restart');
+  }
+)
+.after(function(options) {
+  options.idex++;
+})
+.done(function(options) {
+  process.stdout.write('arr: ');
+  console.log(options.arr);
+})
+.run({arr: [], idex: 0});
+```
+
 ### Create plugins to repeat setup
 
 ```javascript

lib/index.js

@@ -64,12 +64,13 @@ Stewardess.prototype.run = function() {
 
   // push the callback onto the arguments
   args.push(function(err) {
-    if (err && [ 'break', 'skip', 'previous', 'repeat' ].indexOf(err) === -1) return error(err);
+    if (err && [ 'restart', 'break', 'skip', 'previous', 'repeat' ].indexOf(err) === -1) return error(err);
     after(fnName);
     if (err === 'break') return done();
     if (err === 'skip') queuePos += 1;
     if (err === 'repeat') queuePos -= 1;
     if (err === 'previous') queuePos = Math.max(queuePos - 2, 0);
+    if (err === 'restart') queuePos = 0;
     nextTick(next);
   });
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "stewardess",
-  "version": "0.2.5",
+  "version": "0.2.6",
   "description": "serial async flow control",
   "main": "index.js",
   "scripts": {

test/begin.js

@@ -0,0 +1,23 @@
+"use strict";
+var stewardess = require('../index');
+
+stewardess(
+  function first(options, next) {
+    return next(options.idex > 10 ? 'skip' : null);
+  },
+  function second(options, next) {
+    options.arr.push(options.idex);
+    return next();
+  },
+  function third(options, next) {
+    return next(options.idex > 10 ? null : 'restart');
+  }
+)
+.after(function(options) {
+  options.idex++;
+})
+.done(function(options) {
+  process.stdout.write('arr: ');
+  console.log(options.arr);
+})
+.run({arr: [], idex: 0});