@class _SYCountedSemaphore, NSMutableDictionary, NSMutableIndexSet, NSMutableArray, NSObject, SYMessageStatusRecord;
@protocol OS_dispatch_source, OS_dispatch_queue, OS_os_activity;

@interface SYSendingSession : SYSession {
    NSObject<OS_dispatch_source> *_stateUpdateSource;
    NSObject<OS_dispatch_source> *_sessionTimer;
    NSObject<OS_dispatch_source> *_messageTimer;
    NSObject<OS_dispatch_queue> *_changeFetcherQueue;
    _SYCountedSemaphore *_changeConcurrencySemaphore;
    NSObject<OS_os_activity> *_changeWaitActivity;
    unsigned long long _batchIndex;
    NSMutableIndexSet *_ackedBatchIndices;
    NSObject<OS_os_activity> *_sessionActivity;
    double _sessionStartTime;
    NSMutableDictionary *_batchObjectIDsByBatchIndex;
    SYMessageStatusRecord *_startMessageID;
    SYMessageStatusRecord *_endMessageID;
    NSMutableArray *_batchMessageIDs;
    struct os_unfair_lock_s { unsigned int _os_unfair_lock_opaque; } _flagsLock;
    struct { unsigned char state : 4; unsigned char canRestart : 1; unsigned char canRollback : 1; unsigned char isResetSync : 1; unsigned char started : 1; unsigned char cancelled : 1; unsigned char completed : 1; unsigned char remoteStartSent : 1; unsigned char remoteStartConfirmed : 1; unsigned char remoteEndSent : 1; unsigned char remoteEndConfirmed : 1; unsigned char localErrorOccurred : 1; } _flags;
}

- (BOOL)_handleEndSessionResponse:(id)a0 error:(id *)a1;
- (BOOL)_handleSyncBatchResponse:(id)a0 error:(id *)a1;
- (id)_newMessageHeader;
- (BOOL)isSending;
- (BOOL)wasCancelled;
- (void)start:(id /* block */)a0;
- (unsigned int)state;
- (BOOL)_handleRestartSessionResponse:(id)a0 error:(id *)a1;
- (void)setState:(unsigned int)a0;
- (BOOL)_handleStartSessionResponse:(id)a0 error:(id *)a1;
- (void).cxx_destruct;
- (void)cancelWithError:(id)a0;
- (void)_fetchNextBatch;
- (BOOL)_hasSentEnd;
- (void)_continue;
- (BOOL)isResetSync;
- (void)_confirmedStart;
- (void)setCanRollback:(BOOL)a0;
- (void)_confirmedEnd;
- (void)_handleEndSession:(id)a0 response:(id)a1 completion:(id /* block */)a2;
- (void)_handleRestartSession:(id)a0 response:(id)a1 completion:(id /* block */)a2;
- (void)_handleSyncBatch:(id)a0 response:(id)a1 completion:(id /* block */)a2;
- (void)_installStateListener;
- (void)_installTimers;
- (BOOL)_localErrorOccurred;
- (void)_notifyErrorAndShutdown;
- (void)_peerProcessedMessageWithIdentifier:(id)a0 userInfo:(id)a1;
- (void)_processNextState;
- (void)_resolvedIdentifier:(id)a0 forResponse:(id)a1;
- (void)_resolvedIdentifierForRequest:(id)a0;
- (void)_sendEndSessionAndError:(id)a0;
- (void)_sendSyncBatch:(id)a0 nextState:(unsigned int)a1;
- (void)_sendSyncCancelled;
- (void)_sendSyncCompleteAndRunBlock:(id /* block */)a0;
- (void)_sendSyncRestart;
- (void)_sentEnd;
- (void)_sentMessageWithIdentifier:(id)a0 userInfo:(id)a1;
- (void)_sentStart;
- (void)_sessionFinished;
- (void)_setCancelled;
- (void)_setComplete;
- (void)_setLocalErrorOccurred;
- (void)_setMessageTimer;
- (void)_setStateQuietly:(unsigned int)a0;
- (void)_setupChangeConcurrency;
- (void)_startFailedForStateChangeWithError:(id)a0;
- (void)_tweakMessageHeader:(id)a0;
- (void)_waitForMessageWindow;
- (BOOL)canRestart;
- (BOOL)canRollback;
- (id)initWithService:(id)a0 isReset:(BOOL)a1;
- (double)remainingSessionTime;
- (void)setCanRestart:(BOOL)a0;

@end