replace var/each with accumulate

examples/acquire-wan-address.fnl

@@ -33,12 +33,11 @@
 (fn run []
   (let [[state-directory wan-device] arg
         dir (svc.open state-directory)]
-    (var addresses [])
+    (accumulate [addresses []
-    (while true
+                 v (dir:events)]
-      (while (not (dir:ready?)) (dir:wait))
+      ;; we don't handle unbound or stopped, where we should
-      (when (. bound-states (dir:output "state"))
+      ;; take the addresses away
-        (set addresses
+      (when (. bound-states (v:output "state"))
-             (update-addresses wan-device addresses (dir:output "address"))))
+        (update-addresses wan-device addresses (v:output "address"))))))
-      (dir:wait))))
 
 { : update-addresses : changes : run }

pkgs/anoia/svc.fnl

@@ -33,6 +33,12 @@
     unknown
     (error (.. "can't read " pathname " of kind \"" unknown.mode "\""))))
 
+(fn events [self]
+  (coroutine.wrap
+   #(while true
+      (while (not (self:ready?)) (self:wait))
+      (coroutine.yield self)
+      (self:wait))))
 
 (fn open [directory]
   (let [watcher (watch-fsevents directory)
@@ -44,6 +50,7 @@
      :output (fn [_ filename]
                (read-value (.. directory "/" filename)))
      :close #(watcher:close)
+     : events
      }))
 
 { : open }