@class NSString, EMQuery, EMMessageRepository, EMObjectID, EFCancelationToken;
@protocol EFScheduler, EFCancelable, EMQueryResultsObserver;

@interface _EMMessageRepositoryQueryObserver : NSObject <EMMessageListItemQueryResultsObserver, EMRecoverableObserver> {
    EMMessageRepository *_repository;
    EMQuery *_query;
    EMObjectID *_observationIdentifier;
    id<EMQueryResultsObserver> _observer;
    EFCancelationToken *_token;
    id<EFCancelable> _remoteCancelable;
    id<EFScheduler> _recoveryScheduler;
    struct os_unfair_lock_s { unsigned int _os_unfair_lock_opaque; } _recoveryLock;
    long long _recoveryAttempt;
    BOOL _recoveryIsScheduled;
}

@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;

- (void)dealloc;
- (void).cxx_destruct;
- (void)cancel;
- (void)_performQueryWithRemoteConnection:(id)a0 forRecovery:(BOOL)a1;
- (id)initWithRepository:(id)a0 query:(id)a1 observer:(id)a2;
- (void)observer:(id)a0 matchedAddedObjectIDs:(id)a1 after:(id)a2 extraInfo:(id)a3;
- (void)observer:(id)a0 matchedAddedObjectIDs:(id)a1 before:(id)a2 extraInfo:(id)a3;
- (void)observer:(id)a0 matchedChangesForObjectIDs:(id)a1;
- (void)observer:(id)a0 matchedDeletedObjectIDs:(id)a1;
- (void)observer:(id)a0 matchedMovedObjectIDs:(id)a1 after:(id)a2;
- (void)observer:(id)a0 matchedMovedObjectIDs:(id)a1 before:(id)a2;
- (void)observer:(id)a0 matchedOldestItemsUpdatedForMailboxes:(id)a1;
- (void)observer:(id)a0 replacedExistingObjectID:(id)a1 withNewObjectID:(id)a2;
- (void)observer:(id)a0 wasUpdated:(id)a1;
- (void)observerDidFinishInitialLoad:(id)a0;
- (void)observerDidFinishRemoteSearch:(id)a0;
- (void)observerWillRestart:(id)a0;
- (void)performWithRemoteConnection:(id)a0;
- (void)recoverWithRemoteConnection:(id)a0;
- (void)refreshQueryWithRemoteConnection:(id)a0;
- (id)trampoliningObserver;

@end