OnComplete nunca se llamó con toSortedList () y groupBy ()

Actualmente estoy usando la Biblioteca de ReactiveLocation de Android ( Github ). LastKnownLocationObservable ( Code ) funciona según lo previsto. Estoy usando flatMap para search estaciones cercanas desde un DB y (debido a su dominio) estoy creando un model a partir de los datos. Así que tengo una list de elementos y estoy creando el nuevo Observable en flatMap con Observable.from(data) .

Luego quiero orderar las ubicaciones, filtrarlas y agruparlas.

 .toSortedList() .flatMap { Observable.from(it) } .filter { it.distance <= (maxDistance.toDouble() * 1000) } .groupBy { //Group the stations in categories if (it.distance <= maxDistance && it.favorite) { "nearbyFavorite" } else if (it.favorite) { "outOfReachFavorite" } else { "nearby" } } 

Sin embargo, el onComplete nunca se llama cuando me suscribo al Observable. The Observable simplemente se detiene en toSortedList() .

Suscribirse:

 .subscribe(object: Subscriber<GroupedObservable<String, NearbyLocationItem>>() { override fun onNext(p0: GroupedObservable<String, NearbyLocationItem>?) { val locationItems = ArrayList<NearbyLocationItem>() p0.subscribe { loc -> locationItems.add(loc) } locations.put(p0.key, locationItems) } override fun onCompleted() { Log.d(javaClass.simpleName, "Never called") } override fun onError(p0: Throwable?) { } }