Bonjour Discovery 的 RxSwift 和嵌套订阅

Question

我是 Rx 的新手，一直在尝试制作一个解析服务的 Bonjour 发现客户端。这命令式地做起来非常简单，但我想用 RxSwift 试试。

由于发现的 NSNetService 对象需要在解析之前保留，我必须进行嵌套订阅调用，外部订阅用于发现，内部订阅用于解析...但有些事情告诉我这不是最好的方法。

import UIKit
import RxSwift

class BonjourClient: NSObject {

    let disposeBag = DisposeBag()
    var servicesArray = [NSNetService]()

    func startBrowsing() {
        let browser = NSNetServiceBrowser()
        browser.rx_netServiceBrowserDidFindServiceMoreComing
            .subscribeNext { (service: NSNetService) in
                        self.servicesArray.append(service)
                        self.servicesArray.last!.rx_netServiceDidResolveAddress
                            .subscribeNext { (sender: NSNetService) in
                                print("Resolved \(sender.name)")
                                let data = sender.TXTRecordData()
                                let dict: [String: NSData?] = NSNetService.dictionaryFromTXTRecordData(data!)
                                for (key, value) in dict {
                                    print("\(key) : \(String(data: value!, encoding: NSUTF8StringEncoding)!)")
                                }
                        }.addDisposableTo(self.disposeBag)
                        self.servicesArray.last!.resolveWithTimeout(5)
                }.addDisposableTo(disposeBag)
        browser.searchForServicesOfType("_amzn-wplay._tcp.", inDomain: "local.")
        NSRunLoop.currentRunLoop().run()
    }

}

我的代理类如下：

import UIKit
import RxSwift
import RxCocoa

class RxNSNetServiceBrowserDelegateProxy: DelegateProxy, NSNetServiceBrowserDelegate, DelegateProxyType {

    static func currentDelegateFor(object: AnyObject) -> AnyObject? {
        let browser: NSNetServiceBrowser = object as! NSNetServiceBrowser
        return browser.delegate
    }

    static func setCurrentDelegate(delegate: AnyObject?, toObject object: AnyObject) {
        let browser: NSNetServiceBrowser = object as! NSNetServiceBrowser
        browser.delegate = delegate as? NSNetServiceBrowserDelegate
    }

}

class RxNSNetServiceDelegateProxy: DelegateProxy, NSNetServiceDelegate, DelegateProxyType {

    static func currentDelegateFor(object: AnyObject) -> AnyObject? {
        let service: NSNetService = object as! NSNetService
        return service.delegate
    }

    static func setCurrentDelegate(delegate: AnyObject?, toObject object: AnyObject) {
        let service: NSNetService = object as! NSNetService
        service.delegate = delegate as? NSNetServiceDelegate
    }

}

extension NSNetServiceBrowser {

    public var rx_delegate: DelegateProxy {
        return proxyForObject(RxNSNetServiceBrowserDelegateProxy.self, self)
    }

    public var rx_netServiceBrowserDidFindServiceMoreComing: Observable<NSNetService> {
        return rx_delegate.observe("netServiceBrowser:didFindService:moreComing:")
            .map { params in
                let service = params[1] as! NSNetService
                return service
        }
    }

}

extension NSNetService {

    public var rx_delegate: DelegateProxy {
        return proxyForObject(RxNSNetServiceDelegateProxy.self, self)
    }

    public var rx_netServiceDidResolveAddress: Observable<NSNetService> {
        return rx_delegate.observe("netServiceDidResolveAddress:")
            .map { params in
                return params[0] as! NSNetService

        }
    }
}

如果我在 browser.rx_netServiceBrowserDidFindServiceMoreComing 调用之后使用 flatMap 而不是 subscribeNext，则服务将无法解析，因为我无法将它从 [=12] 中保存到数组=] 出于让我无法理解的原因，主要是因为从未接触过 Rx。我一定要使用嵌套调用吗？

我的问题的简短版本是上面的作品，但对我来说似乎很费解。任何想法将不胜感激。

Answer 1

您可以使用 scan 来避免嵌套订阅。它会将 rx_netServiceBrowserDidFindServiceMoreComing 中的每个 NSNetService 添加到数组中。请注意，在这种情况下，您不必将 servicesArray 存储为成员变量，除非您出于其他原因需要它。

然后你可以使用flatMap如下：

browser.rx_netServiceBrowserDidFindServiceMoreComing
    .scan([NSNetService]()) { (services: [NSNetService], service: NSNetService)  in
        return services + [service]
    }.flatMap { (services: [NSNetService]) in
        return services.last!.rx_resolveWithTimeout(5)
    }.subscribeNext { (sender: NSNetService) in
        print("Resolved \(sender.name)")
        let data = sender.TXTRecordData()
        let dict: [String: NSData?] = NSNetService.dictionaryFromTXTRecordData(data!)
        for (key, value) in dict {
            print("\(key) : \(String(data: value!, encoding: NSUTF8StringEncoding)!)")
        }
}.addDisposableTo(disposeBag)

这需要在 NSNetService 扩展中添加一个方法，因为您必须 return 来自 flatMap 的 Observable:

extension NSNetService {
//existing methods omitted
 public func rx_resolveWithTimeout(timeout: NSTimeInterval) -> Observable<NSNetService> {
        self.resolveWithTimeout(timeout)
        return rx_netServiceDidResolveAddress.filter {
            [=11=] == self
        }
    }
}

Bonjour Discovery 的 RxSwift 和嵌套订阅

RxSwift and Nested Subscriptions for Bonjour Discovery

bonjour

swift

rx-swift