は、ネットワーク要求

Question

の結果が含まれている私はネットワーク要求の結果をラップするRxAlamofireで動作するようにしようとしているこんにちは

私の目標は、どちらか含まれていること、要求を発射JSON応答を処理して作成することで、観察可能ネットワーク操作の成功または何らかのエラーが発生する。他の場所で

私は、エラーメッセージで観察を作成する関数を呼び出すと、それに加入し、それが成功したか失敗であるかどうかをユーザーに通知することができ

私の実装では、怒鳴る

func discoverMovieList(for url: String, withPagg page: Int) -> Observable<Any> { 
     let requestUrl = "\(url)&page=\(page)" 

     return RxAlamofire.json(.get, requestUrl) 
      .map{ jsonResponse in 
        self.createOrUpdateMoviesList(from: JSON(jsonResponse)) 
       } 
    } 

どのように私たちすることができますですコードを修正し、プロセスの結果を他の場所からどのように呼び出すかを通知します。ヘルプは非常に感謝しています。ありがとう！

Answer 1

subscribeメソッドを使用して提供する、複数のライフサイクルコールバックを定義できます。この例では、使用量がこのようなものになるだろう：

discoverMovieList(for: "http://some.url", withPagg: 2) 
    .subscribe(
    onNext: { movies in 
     uiElement.string = "Movie list received" 
    }, 
    onError: { error in 
     uiElement.string = "Something went wrong" 
    } 
) 
    .disposed(by: disposeBag) 

disposeBagは、サブスクリプションを保持するために使用されているので、disposeBagが解除されると、サブスクリプションがキャンセルされた（私たちの場合には、ネットワーク呼び出しが中止されることになります）。