Skip to content

Commit

Permalink
Renamings due to review
Browse files Browse the repository at this point in the history
  • Loading branch information
pouljohn1 committed Apr 20, 2018
1 parent 7172e48 commit f7c52a1
Showing 1 changed file with 3 additions and 3 deletions.
Expand Up @@ -119,15 +119,15 @@ final class RxBluetoothKitService {
func discoverServices(for peripheral: Peripheral) {
let isConnected = peripheral.isConnected

let createConnectedObservable = { return peripheral.discoverServices(nil).asObservable() }
let createDisconnectedObservable = {
let connectedObservableCreator = { return peripheral.discoverServices(nil).asObservable() }
let connectObservableCreator = {
return peripheral.establishConnection()
.do(onNext: { [weak self] _ in
self?.observeDisconnect(for: peripheral)
})
.flatMap { $0.discoverServices(nil) }
}
let observable = isConnected ? createConnectedObservable(): createDisconnectedObservable()
let observable = isConnected ? connectedObservableCreator(): connectObservableCreator()
let disposable = observable.subscribe(onNext: { [weak self] services in
self?.discoveredServicesSubject.onNext(Result.success(services))
}, onError: { [weak self] error in
Expand Down

0 comments on commit f7c52a1

Please sign in to comment.