diff --git a/lib/index.js b/lib/index.js
index 3125db6..4d07c13 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -130,15 +130,13 @@ const Channel = function(length = 0) {
             */
 
             if (Channel.isChannel(arg)) {
-              await arg.forEach(value => {
-                output.push(value);
-              });
+              await arg.forEach(output.push);
             } else {
               await output.push(arg);
             }
           }
 
-          output.close();
+          await output.close();
         })();
 
         return output;