             .itemSelected
             .subscribe(onNext: handleSelectedItem)
         
-        epokStream.subscribe(onNext: handleEpokResults, onError: handleError)
+        epokStream
+            .subscribe(onNext: handleEpokResults, onError: handleError)
             .addDisposableTo(disposeBag)
         
         

                    .scan(dataMatrix, accumulator: { (matrix, item) -> [[String: Any]] in
                        guard jsonArray.count > 0, jsonArray.count > index else { return dataMatrix }
                        
                        let addresses = item as! [[String: Any]]
                        var place = jsonArray[index]
                        var filteredAddresses: [[String: Any]] = []
                        
                        for address in addresses {
                            if var normalizedAddresses = address["direccionesNormalizadas"] as? [[String: Any]],
                            let content = jsonArray[index]["contenido"] as? [[String: Any]] {
                                var name: String?
                                
                                for item in content {
                                    if let nameId = item["nombreId"] as? String, nameId == "nombre", let value = item["valor"] as? String {
                                        name = value
                                    }
                                }
                                
                                for (itemIndex, _) in normalizedAddresses.enumerated() {
                                    normalizedAddresses[itemIndex]["label"] = name
                                }
                                
                                filteredAddresses = filteredAddresses + normalizedAddresses
                            }
                        }
                        

                guard let jsonArray = result as? [[String: Any]] else { return Observable.empty() }
                
                var requests: [Observable<Any>] = []
                var places: [String: String] = [:]
                var dataMatrix: [[String: Any]] = []
                var index = 0;
                
                for json in jsonArray {
                    if let normalizedAddress = json["direccionNormalizada"] as? String, !normalizedAddress.isEmpty,
                        let content = json["contenido"] as? [[String: Any]] {
                        var name: String?
                        
                        for item in content {
                            if let nameId = item["nombreId"] as? String, nameId == "nombre", let value = item["valor"] as? String {
                                name = value
                            }
                        }

                        if name != nil {
                            requests.append(self.makeNormalizationRequest(normalizedAddress))
                            places[normalizedAddress] = name!
                        }
                    }
                }

                return Observable.from(requests)
                    .merge()
                    .toArray()
