@class NSString, HMETopicRouter, NSObject; @protocol OS_os_log, HMELastEventStoreReadHandle, HMELastEventStoreWriteHandle, OS_dispatch_queue, HMERouterClientDelegate; @interface HMERouterClient : NSObject { NSObject *_logger; } @property (readonly) id eventStoreReadHandle; @property (readonly) id eventStoreWriteHandle; @property (readonly) NSObject *queue; @property (readonly) HMETopicRouter *topicRouter; @property (weak) id privateDelegate; @property (readonly, nonatomic) BOOL isCachedEventSourceCurrentProcess; @property (readonly) unsigned long long hash; @property (readonly) Class superclass; @property (readonly, copy) NSString *description; @property (readonly, copy) NSString *debugDescription; - (id)upstreamTopicsForTopic:(id)a0; - (id)initWithQueue:(id)a0 storeReadHandle:(id)a1 logger:(id)a2; - (void)registerConsumer:(id)a0 topicFilters:(id)a1 completion:(id /* block */)a2; - (void)processReceivedEvents:(id)a0; - (id)forwardingTopicsForTopics:(id)a0; - (id)dumpStateDescription; - (void)changeRegistrationsForConsumer:(id)a0 topicFilterAdditions:(id)a1 topicFilterRemovals:(id)a2 completion:(id /* block */)a3; - (void)processReceivedCachedEvents:(id)a0; - (id)initWithQueue:(id)a0 storeReadHandle:(id)a1 storeWriteHandle:(id)a2 logger:(id)a3; - (id)initWithQueue:(id)a0; - (void)changeRegistrationsSyncForConsumer:(id)a0 topicFilterAdditions:(id)a1 topicFilterRemovals:(id)a2 completion:(id /* block */)a3; - (void)unregisterConsumerSync:(id)a0 completion:(id /* block */)a1; - (void)didChangeRegistrationsWithTopicFilterAdditions:(id)a0 removals:(id)a1; - (id)synchronousSubscriptionProvider; - (void)unregisterConsumer:(id)a0 completion:(id /* block */)a1; - (unsigned long long)willWriteToStore; - (BOOL)isActiveForSaving; - (void).cxx_destruct; - (BOOL)handleChangeRegistrationsWithTopicFilterAdditions:(id)a0 removals:(id)a1; - (void)unregisterConsumer:(id)a0 topicFilters:(id)a1 completion:(id /* block */)a2; - (void)finishedWritingToStore:(unsigned long long)a0; @end