46

現在、RxSwift を機能させようとしています。そして、カスタム Observable を作成したいと思います。しかし、私は何か間違ったことをしていると思います。

私が行っていることをこの最小限のサンプルにまとめました。

import Foundation
import RxSwift

class Example
{

    let exampleObservable : Observable<String> = Observable.create { (observer) in
        observer.on(.Next("hello"))
        observer.on(.Completed)

        return AnonymousDisposable { }
    }

    let exampleObserver : AnyObserver<String>?

    func run()
    {
        self.exampleObserver = exampleObservable.subscribeNext({ (text) -> Void in
            print(text)
        })  
    }

}

let ex = Example()
ex.run()

これは正しいです？run メソッドでは、subscribeNext メソッドが XCode によってそのようにオートコンプリートされます。

例

しかし、実行すると、次のコンパイルエラーが発生します。

Cannot Invoke 'substribeNext' with an argument list of type ((String) -> Void)
4

4 に答える 4

73

RxExamples理解を深めるために使用できRxSwiftます。RxSwift レポで見つけました。RxSwiftを理解するのに役立ちました。

Alamofireでは、 と を使用して簡単なリクエストを送信してみましょうRxSwift。まず、リクエスト関数を書きます:

 func getApi() -> Observable<AnyObject?> {
    return create{ observer in
        let request = Alamofire.request(.GET, "http://someapiurl.com", parameters: nil)
            .response(completionHandler:  { request, response, data, error in
                if ((error) != nil) {
                    observer.on(.Error(error!))
                } else {
                    observer.on(.Next(data))
                    observer.on(.Completed)
                }
            });
        return AnonymousDisposable {
            request.cancel()
        }
    }
}

getApi()メソッドはリクエストを送信し、 を使用してサーバーからレスポンスを取得しますAlamofire。RxSwift成功またはエラー メッセージの送信にオブザーバーを使用しました。次に、この関数を呼び出す必要があります。rx_tapボタンに使用できます：

class ViewController: UIViewController {

        var disposeBag = DisposeBag()

        override func viewDidLoad() {
            super.viewDidLoad()


            getApi()
                // Set 3 attempts to get response
                .retry(3)
                // Set 2 seconds timeout
                .timeout(2, MainScheduler.sharedInstance)
                // Subscribe in background thread
                .subscribeOn(Dependencies.sharedDependencies.backgroundWorkScheduler)
                // Observe in main thread
                .observeOn(Dependencies.sharedDependencies.mainScheduler)
                // Subscribe on observer
                .subscribe(
                    onNext: { data in
                        do {
                            let post = try NSJSONSerialization.JSONObjectWithData(data as! NSData, options: []) as! NSDictionary
                            print(post)
                        } catch  {
                            print(NSString(data: data as! NSData, encoding: NSUTF8StringEncoding))
                            return
                        }
                    },
                    onError: { error in
                        print(error)
                    },
                    onCompleted: {
                        print("Completed")
                    },
                    onDisposed: {
                        print("Disposed")
                    }
                )
                .addDisposableTo(disposeBag)
        }
    }

これは私の簡単な例です。これがお役に立てば幸いです。ReactiveXは大きなチャンスです。がんばれRxSwift！

于 2016-01-14T12:15:57.113 に答える