581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
|
#endif
} else
OF_ENSURE(0);
}
- (void)run
{
for (;;) {
|
>
|
>
|
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
|
#endif
} else
OF_ENSURE(0);
}
- (void)run
{
running = YES;
while (running) {
void *pool = objc_autoreleasePoolPush();
OFDate *now = [OFDate date];
OFTimer *timer;
OFDate *nextTimer;
#ifdef OF_HAVE_THREADS
[timersQueueLock lock];
|
643
644
645
646
647
648
649
650
|
*/
[streamObserver observe];
}
objc_autoreleasePoolPop(pool);
}
}
@end
|
>
>
>
>
>
>
|
645
646
647
648
649
650
651
652
653
654
655
656
657
658
|
*/
[streamObserver observe];
}
objc_autoreleasePoolPop(pool);
}
}
- (void)stop
{
running = NO;
[streamObserver cancel];
}
@end
|