Skip to content

Commit

Permalink
Check if self is not null in BleDisClient.readDisInfo & readDisInfoWi…
Browse files Browse the repository at this point in the history
…thKeysAsStrings.

polarofficial#503
  • Loading branch information
korzonkiee committed Nov 27, 2024
1 parent 1076409 commit 771c622
Showing 1 changed file with 12 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,12 @@ public class BleDisClient: BleGattClientBase {
/// - Returns: Observable stream
public func readDisInfo(_ checkConnection: Bool) -> Observable<(CBUUID,String)> {
var object: RxObserver<(CBUUID ,String)>!
return Observable.create{ observer in
return Observable.create{ [weak self] observer in
guard let self = self else {
observer.onCompleted()
return Disposables.create()
}

object = RxObserver<(CBUUID ,String)>.init(obs: observer)
if !checkConnection || self.gattServiceTransmitter?.isConnected() ?? false {
self.observers.append(object)
Expand All @@ -116,7 +121,12 @@ public class BleDisClient: BleGattClientBase {

public func readDisInfoWithKeysAsStrings(_ checkConnection: Bool) -> Observable<(String, String)> {
var object: RxObserver<(String, String)>!
return Observable.create { observer in
return Observable.create { [weak self] observer in
guard let self = self else {
observer.onCompleted()
return Disposables.create()
}

object = RxObserver<(String, String)>.init(obs: observer)
if !checkConnection || self.gattServiceTransmitter?.isConnected() ?? false {
self.observersStringKey.append(object)
Expand Down

0 comments on commit 771c622

Please sign in to comment.