Add every.

lib/index.js

@@ -103,6 +103,20 @@ const Channel = function (bufferLength = 0) {
   }
 
   const readOnly = Object.freeze({
+    every: async (callbackfn, thisArg) => {
+      for (;;) {
+        const value = await readOnly.shift()
+
+        if (value === undefined) {
+          return true
+        } else {
+          if (!callbackfn.call(thisArg, value)) {
+            return false
+          }
+        }
+      }
+    },
+
     filter: (callbackfn, thisArg) => {
       const output = Channel()