RxSwiftとParse-Serverでのポーリング

Question

私はParse-ServerをバックエンドとRxSwiftとして使用するApple TVアプリケーションで作業しています。私はテレビストリーミングアプリケーションの認証システムと同様の認証システムを設定しようとしています。

今私はコード、デバイスID、およびセッショントークン列を持つ認証データベース内にAuthenticationCodeオブジェクトを持っています。私はオブジェクトのフェッチを5秒ごとに実行するためにRxSwiftの間隔を使用しようとしており、セッショントークン列が記入されているかどうかを確認しています。ここで

コードです：

func poll(authorizationCode: AuthorizationCode) -> Observable<AuthorizationCode> { 
    return Observable<Int>.interval(5, scheduler: MainScheduler.instance).flatMap({ _ in 
     return Observable<AuthorizationCode>.create { observer -> Disposable in 
      authorizationCode.fetchInBackground(block: { (authorizationCode, error) in 
       if let authorizationCode = authorizationCode as? AuthorizationCode { 
        observer.onNext(authorizationCode) 

        if authorizationCode.sessionToken != nil { 
         observer.onCompleted() 
        } 
       } else if let error = error { 
        observer.onError(error) 
       } 
      }) 

      return Disposables.create() 
     } 
    }) 
} 

は、私がonNextイベントで、私は、オブジェクトをフェッチし、私はセッションコードが存在する場合のシーケンスを終了するたびに発光しています。

このコードで問題が発生しているのは、セッショントークンが記入され、onCompletedが呼び出された後でも、タイマーはまだ起動し、サブスクライバはonCompletedイベントを取得しないということです。

これに関するお手伝いがあります。

また、どうやってこれをやっていけばいいか教えてください。

私はParse-Serverライブクエリを使用しますが、現在はtvOSをサポートしていません。

ありがとうございました。

Answer 1

更新日：

はこのお試しください：

func poll(authorizationCode: AuthorizationCode) -> Observable<AuthorizationCode> { 
    // 1. Return the Observable 
    return Observable<AuthorizationCode>.create { observer -> Disposable in 
     // 2. We create the interval here 
     let interval = Observable<Int>.interval(5, scheduler: MainScheduler.instance) 

     // 3. Interval subscription 
     let subscription = 
     interval.subscribe(onNext: { _ in 
      // 4. Fetch 
      authorizationCode.fetchInBackground(block: { (authorizationCode, error) in 
       // 5. onNext, onCompleted, onError 
       if let authorizationCode = authorizationCode as? AuthorizationCode { 
        observer.onNext(authorizationCode) 

        if authorizationCode.sessionToken != nil { 
         observer.onCompleted() 
        } 
       } else if let error = error { 
        observer.onError(error) 
       } 
      }) 
     }) 

     return Disposables.create{ 
      subscription.dispose() 
     } 
    } 
}