xtdb.tx.subscribe — com.xtdb/xtdb-core 1.24.0

->notifying-subscriber-handler clj

(->notifying-subscriber-handler latest-submitted-tx)

completable-thread clj

(completable-thread f)

handle-polling-subscription clj

(handle-polling-subscription tx-log after-tx-id {:keys [poll-sleep-duration]} f)

PNotifyingSubscriberHandler clj protocol

handle-notifying-subscriber clj

(handle-notifying-subscriber _ tx-log after-tx-id f)

notify-tx! clj

(notify-tx! _ tx)

subscription-thread-factory clj