   (reify StreamObserver
     (onNext [this event]
       (case (.getEventCase ^EventsPackage$Event event)
-        EventsPackage$Event$EventCase/BLOCK (deliver-block-to-channels (.getBlock event))
+        EventsPackage$Event$EventCase/BLOCK (deliver-block-events-to-channels (.getBlock event))
         EventsPackage$Event$EventCase/REGISTER nil ;; init
         ;; EventsPackage$Event$EventCase/CHAINCODE_EVENT ;; FIXME: not used??
         EventsPackage$Event$EventCase/UNREGISTER nil;; shutdown

    (onCompleted [this]
      (async/put! ch :done))))



(defn make-event-hub???
  [user peer]
  (let [ch (async/chan (async/sliding-buffer default-sliding-buffer-size))
        ^StreamObserver observer (transaction-observer ch)

;;      - Java: part of the Java SDK for Hyperledger Fabric. Source code can be found here
;;      - Golang: an example event listener client can be found here
;;

(defonce block-metadata-index-map
  (zipmap [:signatures :last-config :transactions-filter :orderer]
