@class DTXMessageTransmitter, NSString, DTXMessageParser, NSSet, NSMutableDictionary, DTXTransport, NSDictionary, NSMutableArray, NSObject, DTXResourceTracker, DTXChannel;
@protocol OS_dispatch_queue, DTXBlockCompressor, OS_dispatch_semaphore;
@interface DTXConnection : NSObject <DTXConnectionRemoteReceiveQueueCalls, DTXMessenger> {
NSObject<OS_dispatch_queue> *_outgoing_message_queue;
NSObject<OS_dispatch_queue> *_outgoing_control_queue;
DTXTransport *_controlTransport;
NSSet *_permittedBlockCompressors;
NSObject<OS_dispatch_queue> *_receive_queue;
NSObject<OS_dispatch_queue> *_handler_queue;
unsigned int _nextChannelCode;
NSMutableDictionary *_channelsByCode;
NSMutableDictionary *_unconfiguredChannelsByCode;
NSMutableDictionary *_handlersByIdentifier;
NSMutableArray *_protocolHandlers;
NSMutableDictionary *_localCapabilityVersions;
NSMutableDictionary *_localCapabilityClasses;
NSDictionary *_remoteCapabilityVersions;
NSMutableArray *_capabilityOverrideBlocks;
DTXResourceTracker *_resourceTracker;
DTXResourceTracker *_incomingResourceTracker;
NSObject<OS_dispatch_semaphore> *_firstMessageSem;
DTXMessageParser *_incomingParser;
DTXMessageTransmitter *_outgoingTransmitter;
DTXChannel *_defaultChannel;
id /* block */ _channelHandler;
unsigned long long _logMessageCallstackSizeThreshold;
int _remoteCompressionCapabilityVersion;
int _newChannelCompressionHint;
int _compressionTypeForUnspecified;
unsigned long long _compressionMinSizeThreshold;
id<DTXBlockCompressor> _compressor;
}
@property (readonly, retain, nonatomic) DTXChannel *defaultChannel;
@property (readonly, nonatomic) int atomicConnectionNumber;
@property (nonatomic) BOOL tracer;
@property (nonatomic) BOOL remoteTracer;
@property (nonatomic) unsigned long long maximumEnqueueSize;
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;
@property (copy, nonatomic) NSString *label;
+ (void)initialize;
+ (id)connectionToAddress:(id)a0;
+ (void)observeDecompressionExceptionLogging:(id /* block */)a0;
+ (void)registerTransport:(Class)a0 forScheme:(id)a1;
- (void)sendMessage:(id)a0 replyHandler:(id /* block */)a1;
- (void)dealloc;
- (void)suspend;
- (void)setMessageHandler:(id /* block */)a0;
- (void)resume;
- (void).cxx_destruct;
- (void)cancel;
- (id)initWithTransport:(id)a0;
- (BOOL)_addHandler:(id /* block */)a0 forMessage:(unsigned int)a1 channel:(id)a2;
- (void)_notifyOfPublishedCapabilities:(id)a0;
- (id)_sendHeartbeatAsyncWithTimeout:(double)a0;
- (void)_cancelInternal:(id /* block */)a0;
- (void)_channelCanceled:(unsigned int)a0;
- (void)_handleMessageParseException:(id)a0 forChannelCode:(unsigned int)a1 messageID:(unsigned int)a2 fragmentCount:(unsigned int)a3 withPayloadBytes:(const void *)a4 ofLength:(unsigned long long)a5;
- (void)_handleMissingRemoteCapabilities;
- (void)_handleProxyRequestForInterface:(id)a0 interfaceName:(id)a1 peerInterface:(id)a2 peerInterfaceName:(id)a3 handler:(id /* block */)a4;
- (id)_makeProxyChannelWithRemoteInterface:(id)a0 remoteInterfaceName:(id)a1 exportedInterface:(id)a2 exportedInterfaceName:(id)a3;
- (void)_notifyCompressionHint:(unsigned int)a0 forChannelCode:(unsigned int)a1;
- (void)_receiveQueueSetCompressionHint:(unsigned int)a0 onChannel:(id)a1;
- (void)_requestChannelWithCode:(unsigned int)a0 identifier:(id)a1;
- (void)_routeMessage:(id)a0;
- (void)_scheduleMessage:(id)a0 toChannel:(id)a1;
- (void)_setTracerState:(unsigned int)a0;
- (void)_setupWireProtocols;
- (id)_testing_remoteCapabilityVersions;
- (void)_unregisterChannel:(id)a0;
- (void)cancelWithSerializedTransport:(id /* block */)a0;
- (void)handleProxyRequestForInterface:(id)a0 interfaceName:(id)a1 peerInterface:(id)a2 peerInterfaceName:(id)a3 handler:(id /* block */)a4;
- (void)handleProxyRequestForInterface:(id)a0 peerInterface:(id)a1 handler:(id /* block */)a2;
- (id)localCapabilities;
- (id)makeChannelWithIdentifier:(id)a0;
- (id)makeProxyChannelWithRemoteInterface:(id)a0 exportedInterface:(id)a1;
- (id)makeProxyChannelWithRemoteInterface:(id)a0 remoteInterfaceName:(id)a1 exportedInterface:(id)a2 exportedInterfaceName:(id)a3;
- (void)overridePermittedBlockCompressors:(id)a0;
- (double)preflightSynchronouslyWithTimeout:(double)a0;
- (void)publishCapability:(id)a0 withVersion:(int)a1 forClass:(Class)a2;
- (BOOL)publishCapability:(id)a0 withVersion:(int)a1 forClass:(Class)a2 error:(id *)a3;
- (void)publishServicesInImagePath:(id)a0;
- (id)publishedAddresses;
- (void)registerCapabilityOverrideBlock:(id /* block */)a0;
- (void)registerDisconnectHandler:(id /* block */)a0;
- (int)remoteCapabilityVersion:(id)a0;
- (id)remoteCapabilityVersions;
- (void)replaceCompressorForCompression:(id)a0;
- (void)replaceCompressorForDecompression:(id)a0;
- (void)sendControlAsync:(id)a0 replyHandler:(id /* block */)a1;
- (void)sendControlSync:(id)a0 replyHandler:(id /* block */)a1;
- (BOOL)sendMessage:(id)a0 fromChannel:(id)a1 sendMode:(int)a2 syncWithReply:(BOOL)a3 replyHandler:(id /* block */)a4;
- (BOOL)sendMessageAsync:(id)a0 replyHandler:(id /* block */)a1;
- (void)sendMessageSync:(id)a0 replyHandler:(id /* block */)a1;
- (void)setChannelHandler:(id /* block */)a0;
- (void)setCompressionHint:(int)a0 forChannel:(id)a1;
- (void)setDispatchTarget:(id)a0;
@end