     fileprivate var resumeObserver: NotificationObserver?
     fileprivate var postCreatedObserver: NotificationObserver?
 
-    init(){
+    init() {
         pauseObserver = NotificationObserver(notification: NewContentNotifications.pause) { [weak self] _ in
             self?.pauseCount += 1
         }

        guard pauseCount == 0 else { return }

        stopPolling()
        let (restart, done) = afterN(restartPolling)
        checkForNewNotifications(restart())
        checkForNewFollowingContent(restart())
        done()
    }

    func updateCreatedAt(_ jsonables: [JSONAble], streamKind: StreamKind) {

    static let resume = TypedNotification<()>(name: "NewContentService-resume")
}


class NewContentService {
    fileprivate var timer: Timer?
    fileprivate var pauseCount = 0
