This resolves an issue AOT'ing when using https://github.com/griffinbank/rules_clojure

Author: arohner

src/manifold/stream.clj

@@ -297,10 +297,6 @@
   ([^IEventSource source default-val ^double timeout timeout-val]
    (.take source default-val false timeout timeout-val)))
 
-;;;
-
-(require '[manifold.stream.graph])
-
 (defn connect
   "Connects a source to a sink, propagating all messages from the former into the latter.
 
@@ -331,7 +327,7 @@
          connector (.connector ^IEventSource source sink)]
      (if connector
        (connector source sink options)
-       (manifold.stream.graph/connect source sink options))
+       ((requiring-resolve 'manifold.stream.graph/connect) source sink options))
      nil)))
 
 ;;;
@@ -866,7 +862,7 @@
   (isSynchronous [_]
     false)
   (downstream [this]
-    (manifold.stream.graph/downstream this))
+    ((requiring-resolve 'manifold.stream.graph/downstream) this))
   (close [_]
     (.close ^IEventStream buf))
   (description [_]

src/manifold/stream/core.clj

@@ -86,7 +86,7 @@
     (alterMeta [_ f# args#]
       (manifold.utils/with-lock* ~'lock
         (set! ~'__mta (apply f# ~'__mta args#))))
-    (~'downstream [this#] (manifold.stream.graph/downstream this#))
+    (~'downstream [this#] ((requiring-resolve 'manifold.stream.graph/downstream) this#))
     (~'weakHandle [this# ref-queue#]
       (manifold.utils/with-lock ~'lock
         (or ~'__weakHandle

src/manifold/stream/queue.clj

@@ -2,7 +2,6 @@
   {:no-doc true}
   (:require
     [clj-commons.primitive-math :as p]
-    [manifold.stream.graph :as g]
     [manifold.deferred :as d]
     [manifold.stream.core :as s]
     [manifold.utils :as utils])
@@ -11,7 +10,6 @@
      AtomicReference]
     [java.util.concurrent
      BlockingQueue
-     LinkedBlockingQueue
      TimeUnit]))
 
 (s/def-source BlockingQueueSource