RxSwift toArray（）不订阅

Question

当我订阅前添加toArray（），我没有回调。

googleCalendarUseCase.getEventsFromCalendars(calendars: selectedCalendars).subscribe(onNext: { (event) in 
     print(event.summary) //print thousands of elements 
    }).addDisposableTo(disposeBag) 
    googleCalendarUseCase.getEventsFromCalendars(calendars: selectedCalendars).toArray().subscribe(onNext: { (events) in 
     print(events.count) // Never gets called 
    }).addDisposableTo(disposeBag) 

也许问题是与功能getEventsFromCalendar，但不确定为什么它的工作原理，如果我不这样做的toArray（）：

func getEventsFromCalendars(calendars: [GoogleCalendar.Calendar], nextPageToken: String? = nil) -> Observable<GoogleCalendar.Event> { 
    return Observable<GoogleCalendar.Event>.create { observer -> Disposable in 
     var parameters: [String: Any] = [:] 
     if let nextPageToken = nextPageToken { 
      parameters["pageToken"] = nextPageToken 
     } 
     _ = self.oauthswift.client.get(GoogleCalendarAPI.events, parameters: parameters, success: { (data, response) in 
      if let json = try? JSONSerialization.jsonObject(with: data, options: JSONSerialization.ReadingOptions.allowFragments) as? [String: AnyObject] { 
       if let nextPageToken = self.nextPageToken(json: json) { 
        _ = Observable.of(Observable.from(self.getEventsFromJSON(json: json)), self.getEventsFromCalendars(calendars: calendars, nextPageToken: nextPageToken)) 
         .merge().subscribe(observer) 
       } else { 
        _ = Observable.from(self.getEventsFromJSON(json: json)) 
       } 
      } else { 
       observer.onError(CustomError.other) 
      }}, failure: { (error) in observer.onError(CustomError.noInet) } 
     ) 
     return Disposables.create() 
    } 
} 

Answer 1

使用debug()检查，并确保你得到一个Completed事件（没有toArray()）。一旦源序列完成，toArray()将只发出Array。

Answer 2

那么，如果它不共享（.share） 像

let sharedObservable = googleCalendarUseCase.getEventsFromCalendars(calendars: selectedCalendars).share() 

    sharedObservable.subscribe(onNext: { (event) in 
     print(event.summary) 
    }).addDisposableTo(disposeBag) 

    sharedObservable.toArray().subscribe(onNext: { (events) in 
     print(events.count) 
    }).addDisposableTo(disposeBag)