 ;; remove-chaincode-interest
 ;; get-interested-events
 ;; receive (i/f - block or chaincode)
-
-#_
-(defonce event-type {:register
-                     :block
-                     :chaincode
-                     :rejection
-                     :filtered-block})
-
-(defonce default-sliding-buffer-size 32)
-;; Block event - any block events
-(defonce event-channels (atom []))
-;; Transaction event - matching tx-id
-(defonce tx-id-event-channels (atom {}))
-;; Chaincode event - matching chaincode-id
-(defonce chaincode-channels (atom {}))
 
 (defonce block-metadata-index-map
   (zipmap [:signatures :last-config :transactions-filter :orderer]

(ns clojure-fabric.event-hub
  (:require [clojure-fabric.proto :as proto]
            [clojure-fabric.crypto-suite :as crypto]
            [clojure.core.async :as async])
  (:import io.grpc.stub.StreamObserver
           [com.google.protobuf ByteString]
           io.grpc.ManagedChannel
           org.hyperledger.fabric.protos.msp.Identities$SerializedIdentity

;; disconnect
;; get-peer-address
;; connected?
;; set-peer-address
;; unregister-block-event
;; unregister-chaincode-event
