@class NSString, NSMutableDictionary, NSObject;
@protocol OS_dispatch_queue, OS_xpc_event_publisher;
@interface IPXPCEventStateUpdateStreamSink : NSObject <IPStateUpdateStreamSink, IPXPCEventStateUpdateStreamSubscriberDelegate> {
NSString *_streamName;
NSObject<OS_dispatch_queue> *_queue;
NSObject<OS_xpc_event_publisher> *_publisher;
BOOL _resumed;
BOOL _foundInitialBarrier;
NSMutableDictionary *_subscribers;
}
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;
- (void)resume;
- (void).cxx_destruct;
- (void)_queue_processPublisherEventAction:(unsigned int)a0 token:(unsigned long long)a1 descriptor:(id)a2;
- (id)initWithQueue:(id)a0 streamName:(id)a1;
- (void)sendUpdateMessage:(id)a0;
- (void)subscriber:(id)a0 firePayload:(id)a1;
- (void)subscriber:(id)a0 firePayload:(id)a1 withReply:(id /* block */)a2;
- (void)subscriberFailedHandshake:(id)a0;
@end