fix eventChannel#close issue

esshka · Apr 20, 2016 · 0afd32d · 0afd32d
1 parent c5da0be
commit 0afd32d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/internal/channel.js b/src/internal/channel.js
@@ -143,8 +143,10 @@ export function eventChannel(subscribe, matcher, buffer) {
   return {
     take: chan.take,
     close: () => {
-      chan.close()
-      unsubscribe()
+      if(!chan.__closed__) {
+        chan.close()
+        unsubscribe()
+      }
     }
   }
 }
diff --git a/test/proc/channel.js b/test/proc/channel.js
@@ -9,7 +9,7 @@ test('proc queue store actions', assert => {
 
   let actual = [];
   let dispatch
-  const input = (cb) => dispatch = cb
+  const input = (cb) => { dispatch = cb; return () => {} }
 
 
   function* genFn() {