       (log/debug _name "Async Loop exited because we either received the stop signal or the internal channel closed")
       :exited-successfully)))
 
-(s/defn possibly-recv-internal!
+(s2/defn possibly-recv-internal!
   "Really just refactored to make data flow less opaque"
   [{:keys [_name ->zmq-sock interface stopper in<->ex-chan]
     :as component} :- EventPair

;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
;;; Schema

(s/defrecord EventPairInterface
    [;; send messages to this' async-chan to get them to 0mq.
     in-chan  :- AsyncChannelComponent
     ;; faces outside world.

            [com.frereth.common.util :as util]
            [com.frereth.common.zmq-socket :as zmq-socket]
            [com.stuartsierra.component :as component]
            [component-dsl.system :as cpt-dsl]
            [full.async :refer (<? <?? alts? go-try)]
            [hara.event :refer (raise)]
            [schema.core :as s2]
            [taoensso.timbre :as log])
  (:import [com.frereth.common.async_component AsyncChannelComponent]
           [com.frereth.common.zmq_socket SocketDescription]
