@class NSMutableDictionary, NSString, NSObject, CBScalablePipeManager;
@protocol OS_dispatch_queue;
@interface WPDPipeManager : WPDManager <CBScalablePipeManagerDelegate, NSStreamDelegate> {
unsigned long long _wpPipeDataSignPostID;
}
@property (weak) NSObject<OS_dispatch_queue> *queue;
@property (retain) CBScalablePipeManager *pipeManager;
@property (retain) NSMutableDictionary *endpointsDict;
@property (retain) NSMutableDictionary *peerPipesDict;
@property (retain) NSMutableDictionary *connectionInitiators;
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;
- (id)initWithServer:(id)a0;
- (void)sendRemainingData:(id)a0 wpClient:(id)a1;
- (void)receivedAck:(id)a0 data:(char *)a1 dataSize:(long long)a2;
- (void)scalablePipeManager:(id)a0 didUnregisterEndpoint:(id)a1;
- (void)scalablePipeManager:(id)a0 pipeDidDisconnect:(id)a1 error:(id)a2;
- (void)scalablePipeManager:(id)a0 pipeDidConnect:(id)a1;
- (void)scalablePipeManager:(id)a0 didRegisterEndpoint:(id)a1 error:(id)a2;
- (id)pipeManagerState:(long long)a0;
- (void)update;
- (BOOL)sendVersionInfo:(id)a0;
- (id)streamEvent:(unsigned long long)a0;
- (void)receivedVersionInfo:(id)a0 data:(char *)a1 dataSize:(long long)a2;
- (void)receivedConnectStatus:(id)a0 data:(char *)a1 dataSize:(long long)a2;
- (id)pipeInfo:(id)a0 forClient:(id)a1;
- (id)generateStateDumpStrings;
- (void)handleIncomingPipeData:(id)a0 data:(char *)a1 dataSize:(long long)a2;
- (void)unregisterEndpoint:(id)a0 forClient:(id)a1;
- (void)sendAck:(id)a0 errorCode:(unsigned char)a1;
- (long long)writeDataToPipe:(id)a0 pipe:(id)a1;
- (void)_signpostBegin;
- (void)stream:(id)a0 handleEvent:(unsigned long long)a1;
- (void)receivedPayload:(id)a0 data:(char *)a1 dataSize:(long long)a2;
- (void)channelHasData:(id)a0;
- (void)sendConnectStatus:(id)a0 connectStatus:(unsigned char)a1;
- (void)registerEndpoint:(id)a0 requireAck:(BOOL)a1 requireEncryption:(BOOL)a2 forClient:(id)a3;
- (void)setPipeClientConnectionStatus:(BOOL)a0 forPeer:(id)a1 forClient:(id)a2;
- (void).cxx_destruct;
- (void)_signpostEnd;
- (void)sendErrorResponse:(id)a0 errorCode:(unsigned char)a1;
- (void)sendData:(id)a0 forPeer:(id)a1 forClient:(id)a2;
- (void)sendChannelData:(id)a0;
- (void)invalidatePipeInfo:(id)a0 forPeer:(id)a1;
- (void)receivedError:(id)a0 data:(char *)a1 dataSize:(long long)a2;
- (void)setConnectionInitiator:(BOOL)a0 forPeer:(id)a1 forClient:(id)a2;
@end