diff --git a/example.js b/example.js
index 84dd93b..f1e1b46 100644
--- a/example.js
+++ b/example.js
@@ -28,6 +28,14 @@ function* test_throttle(thread)
     yield thread.throttle(5);
     console.log('at most 5');
     yield setTimeout(thread, 1000);
+    console.log('continue in another generator');
+    yield other_gen(thread);
+}
+
+function* other_gen(thread)
+{
+    yield setTimeout(thread, 1000);
+    console.log('finished in another generator');
 }
 
 for (var i = 0; i < 15; i++)
diff --git a/index.js b/index.js
index 62212f4..0d0014c 100644
--- a/index.js
+++ b/index.js
@@ -32,24 +32,43 @@ function runThread(main, arg, done)
         var v;
         try
         {
-            v = thread.gen.next(pass);
+            v = thread.gens[0].next(pass);
         }
         catch (e)
         {
             v = { done: 1, error: e };
         }
         if (v.done)
+        {
+            // generator finished
+            thread.gens.shift();
+            if (thread.gens.length)
+            {
+                // return to previous generator
+                thread(v.value);
+                return;
+            }
+        }
+        if (typeof v.value == 'object' &&
+            v.value.constructor.constructor == thread.gens[0].constructor.constructor)
+        {
+            // another generator instance returned - add it to stack and call
+            thread.gens.unshift(v.value);
+            thread();
+            return;
+        }
+        if (!thread.gens.length)
         {
             thread._done = true;
             process.nextTick(finishq);
         }
         if (v.error)
             throw v.error;
-        if (v.done && done)
+        if (!thread.gens.length && done)
             done(v.value);
     };
     thread.id = tid++;
-    thread.gen = main(thread, arg);
+    thread.gens = [ main(thread, arg) ];
     thread.throttle = function(count)
     {
         finishq();
@@ -82,6 +101,7 @@ function runThread(main, arg, done)
         return fn;
     };
     thread();
+    return thread;
 }
 
 function runParallel(threads, done)