Hangs Reporting

POSThreadWatchDogReporter.m

@interface POSThreadWatchDogReporter ()
@property (nonatomic, readonly) NSTimeInterval threshold;
@property (nonatomic, readonly) POSThreadWatchDog *watchDog;
@end

@implementation POSThreadWatchDogReporter

- (instancetype)initWithThreshold:(NSTimeInterval)threshold {
    POSRX_CHECK([NSThread isMainThread]);
    thread_t thread = mach_thread_self();
    mach_port_deallocate(mach_task_self(), thread);
    if (self = [super init]) {
        _threshold = threshold;
        _watchDog = [[POSThreadWatchDog alloc]
                     initWithScheduler:RACTargetQueueScheduler.pos_scheduler
                     targetThread:thread
                     pingInterval:1];
    }
    return self;
}

- (void)start {
    @weakify(self);
    [[_watchDog start] subscribeNext:^(POSThreadWatchDogReport *report) {
        @strongify(self);
        BOOL shouldReport = report.hangTime >= self.threshold;
        NSLog(@"[INCOMMING] %@:%@:%@:%@",
              report.ID,
              report.hangerName,
              @(report.hangTime),
              @(report.hangCompleted));
        if (shouldReport && report.hangCompleted) {
            [self p_removeReport:report];
            NSLog(@"[SEND     ] %@", report.ID);
        } else if (shouldReport && !report.hangCompleted) {
            [self p_saveReport:report];
        }
    } error:^(NSError *error) {
        NSLog(@"[ERROR    ] %@", error);
    }];
}

- (void)sendPendingReports {
    
}

- (void)p_saveReport:(POSThreadWatchDogReport *)report {
    NSLog(@"[SAVE     ] %@", report.ID);
}

- (void)p_removeReport:(POSThreadWatchDogReport *)report {
    NSLog(@"[REMOVE   ] %@", report.ID);
}

@end