@class NSMutableDictionary, NSObject;
@protocol OS_dispatch_semaphore;
@interface PPXPCServerPipelinedBatchQueryManager : NSObject {
long long _pipelineDepth;
unsigned long long _pipelinedCallTimeoutNsec;
NSObject<OS_dispatch_semaphore> *_concurrentRequestSem;
NSMutableDictionary *_queryReplyThrottleSemaphores;
_Atomic BOOL _isInterrupted;
}
- (void)_unblockQueryReplyThrottleSemaphore:(id)a0;
- (void)unblockPendingQueries;
- (void)runConcurrentlyWithRequestThrottle:(id /* block */)a0;
- (void)sendBatchedResultForQueryWithName:(id)a0 queryId:(unsigned long long)a1 batchGenerator:(id /* block */)a2 sendError:(id /* block */)a3 sendBatch:(id /* block */)a4;
- (void).cxx_destruct;
- (id)initWithPipelineDepth:(long long)a0 pipelinedCallTimeoutNsec:(unsigned long long)a1 maxConcurrentRequestsPerConnection:(unsigned long long)a2;
- (void)runSynchronouslyWithRequestThrottle:(id /* block */)a0;
- (void)waitForBlockWithRequestThrottle:(id /* block */)a0;
@end