Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

ReactiveExtensions for CBPeripheral, CBCentralManager and CBPeripheralManager #602

Open
wants to merge 5 commits into
base: master
Choose a base branch
from
Open

ReactiveExtensions for CBPeripheral, CBCentralManager and CBPeripheralManager #602

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
4b844f5
Added ReactiveExtensions for CBPeripheral, CBCentralManager and CBPer…
Mar 4, 2019
9ab425a
Removed import Bond from CBPeripheralManager.swift
Mar 4, 2019
ba62625
Fix for didDisconnectPeripheral and didFailToConnectPeripheral
Mar 6, 2019
51e0da3
Merge branch 'master' into CoreBluetooth-extensions
srdanrasic Mar 16, 2019
2bd3046
Merge commit '05df822b7046b4cd45412decc2587daf0e7f218b' into CoreBlue…
Mar 27, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 32 additions & 0 deletions Bond.xcodeproj/project.pbxproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -321,6 +321,15 @@
ECFF44BC21692B5800B5EDB0 /* OutlineChangesetConvertible.swift in Sources */ = {isa = PBXBuildFile; fileRef = ECFF44BB21692B5800B5EDB0 /* OutlineChangesetConvertible.swift */; };
ECFF44BD21692B5800B5EDB0 /* OutlineChangesetConvertible.swift in Sources */ = {isa = PBXBuildFile; fileRef = ECFF44BB21692B5800B5EDB0 /* OutlineChangesetConvertible.swift */; };
ECFF44BE21692B5800B5EDB0 /* OutlineChangesetConvertible.swift in Sources */ = {isa = PBXBuildFile; fileRef = ECFF44BB21692B5800B5EDB0 /* OutlineChangesetConvertible.swift */; };
FCDA454F2229C25A001E0C3D /* CBCentralManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA454E2229C25A001E0C3D /* CBCentralManager.swift */; };
FCDA45502229C25A001E0C3D /* CBCentralManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA454E2229C25A001E0C3D /* CBCentralManager.swift */; };
FCDA45512229C25A001E0C3D /* CBCentralManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA454E2229C25A001E0C3D /* CBCentralManager.swift */; };
FCDA45542229C2DE001E0C3D /* CBPeripheral.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA45532229C2DE001E0C3D /* CBPeripheral.swift */; };
FCDA45552229C2DE001E0C3D /* CBPeripheral.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA45532229C2DE001E0C3D /* CBPeripheral.swift */; };
FCDA45562229C2DE001E0C3D /* CBPeripheral.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA45532229C2DE001E0C3D /* CBPeripheral.swift */; };
FCDA45592229C322001E0C3D /* CBPeripheralManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA45582229C322001E0C3D /* CBPeripheralManager.swift */; };
FCDA455A2229C322001E0C3D /* CBPeripheralManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA45582229C322001E0C3D /* CBPeripheralManager.swift */; };
FCDA455B2229C322001E0C3D /* CBPeripheralManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCDA45582229C322001E0C3D /* CBPeripheralManager.swift */; };
/* End PBXBuildFile section */

/* Begin PBXContainerItemProxy section */
Expand Down Expand Up @@ -538,6 +547,9 @@
ECFF44B02168C21F00B5EDB0 /* Array2D.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Array2D.swift; sourceTree = "<group>"; };
ECFF44B62168F5C000B5EDB0 /* Instantiatable.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Instantiatable.swift; sourceTree = "<group>"; };
ECFF44BB21692B5800B5EDB0 /* OutlineChangesetConvertible.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = OutlineChangesetConvertible.swift; sourceTree = "<group>"; };
FCDA454E2229C25A001E0C3D /* CBCentralManager.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = CBCentralManager.swift; sourceTree = "<group>"; };
FCDA45532229C2DE001E0C3D /* CBPeripheral.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = CBPeripheral.swift; sourceTree = "<group>"; };
FCDA45582229C322001E0C3D /* CBPeripheralManager.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = CBPeripheralManager.swift; sourceTree = "<group>"; };
/* End PBXFileReference section */

/* Begin PBXFrameworksBuildPhase section */
Expand Down Expand Up @@ -708,6 +720,7 @@
ECFF44B62168F5C000B5EDB0 /* Instantiatable.swift */,
90C04D3E1E8F0B1D000077C8 /* Signal+Heartbeat.swift */,
EC0220091F8BE898002F8380 /* Property+BidirectionalMap.swift */,
FCDA45492229C22B001E0C3D /* CoreBluetooth */,
90C04D571E8F0B4A000077C8 /* UIKit */,
90C04D581E8F0B5E000077C8 /* AppKit */,
90C04D591E8F0B75000077C8 /* Shared */,
Expand Down Expand Up @@ -882,6 +895,16 @@
path = "Data Sources";
sourceTree = "<group>";
};
FCDA45492229C22B001E0C3D /* CoreBluetooth */ = {
isa = PBXGroup;
children = (
FCDA454E2229C25A001E0C3D /* CBCentralManager.swift */,
FCDA45532229C2DE001E0C3D /* CBPeripheral.swift */,
FCDA45582229C322001E0C3D /* CBPeripheralManager.swift */,
);
path = CoreBluetooth;
sourceTree = "<group>";
};
/* End PBXGroup section */

/* Begin PBXHeadersBuildPhase section */
Expand Down Expand Up @@ -1154,6 +1177,7 @@
90A4437A1E91390000D611FE /* BNDProtocolProxyBase.m in Sources */,
90A4430F1E9055D100D611FE /* NSSlider.swift in Sources */,
90C04DAF1E8F0B97000077C8 /* UIApplication.swift in Sources */,
FCDA454F2229C25A001E0C3D /* CBCentralManager.swift in Sources */,
EC930F46222B1EA7000D397C /* TreeView.swift in Sources */,
EC0D8D2B21C69BC6003F8EF2 /* UITableView+DataSource.swift in Sources */,
90C04D721E8F0B89000077C8 /* DynamicSubject.swift in Sources */,
Expand All @@ -1167,6 +1191,7 @@
90A443141E9055D200D611FE /* NSView.swift in Sources */,
90C04DB41E8F0B97000077C8 /* UIControl.swift in Sources */,
90C04DC01E8F0B97000077C8 /* UISwitch.swift in Sources */,
FCDA45542229C2DE001E0C3D /* CBPeripheral.swift in Sources */,
EC930F41222B105F000D397C /* TreeProtocol+Differ.swift in Sources */,
EC1F12712167BFB4002F0D1B /* UnorderedCollectionDiff.swift in Sources */,
90C04D731E8F0B89000077C8 /* Observable.swift in Sources */,
Expand Down Expand Up @@ -1219,6 +1244,7 @@
ECAFB8D9200B60AA00EE0669 /* ProtocolProxyController.swift in Sources */,
90C04DB71E8F0B97000077C8 /* UIImageView.swift in Sources */,
EC1F12792167C0B7002F0D1B /* UnorderedCollectionOperation.swift in Sources */,
FCDA45592229C322001E0C3D /* CBPeripheralManager.swift in Sources */,
ECBCE0DC2161712C0078E03B /* UnorderedCollectionChangeset.swift in Sources */,
ECBCE0C921616A710078E03B /* OrderedCollectionChangeset.swift in Sources */,
90C04DBF1E8F0B97000077C8 /* UIStepper.swift in Sources */,
Expand Down Expand Up @@ -1282,6 +1308,7 @@
isa = PBXSourcesBuildPhase;
buildActionMask = 2147483647;
files = (
FCDA455A2229C322001E0C3D /* CBPeripheralManager.swift in Sources */,
90A4437D1E91391B00D611FE /* BNDProtocolProxyBase.m in Sources */,
ECC1A6D1207A18DC00AE762C /* NSTableView+DataSource.swift in Sources */,
90A443361E9055D800D611FE /* UISwitch.swift in Sources */,
Expand Down Expand Up @@ -1324,6 +1351,7 @@
ECBC51BF2161637A00BE80EC /* OrderedCollectionOperation+Strideable+Undo.swift in Sources */,
ECBC51BA2161637A00BE80EC /* ChangesetContainer.swift in Sources */,
ECBCE0C72161696B0078E03B /* OrderedCollectionOperation.swift in Sources */,
FCDA45552229C2DE001E0C3D /* CBPeripheral.swift in Sources */,
90C04D871E8F0B8D000077C8 /* NSTableView.swift in Sources */,
90C04D691E8F0B89000077C8 /* ProtocolProxy.swift in Sources */,
90A4432D1E9055D800D611FE /* UIImageView.swift in Sources */,
Expand Down Expand Up @@ -1359,6 +1387,7 @@
ECAFB8D5200A7E3900EE0669 /* BNDInvocation.swift in Sources */,
ECBC51C22161637A00BE80EC /* OrderedCollectionDiff+IndexPath.swift in Sources */,
90C04D831E8F0B8D000077C8 /* NSProgressIndicator.swift in Sources */,
FCDA45502229C25A001E0C3D /* CBCentralManager.swift in Sources */,
90C04D6C1E8F0B89000077C8 /* NotificationCenter.swift in Sources */,
90A443251E9055D800D611FE /* UIApplication.swift in Sources */,
EC0D8D3021C69C3C003F8EF2 /* UICollectionView+DataSource.swift in Sources */,
Expand All @@ -1382,6 +1411,7 @@
isa = PBXSourcesBuildPhase;
buildActionMask = 2147483647;
files = (
FCDA455B2229C322001E0C3D /* CBPeripheralManager.swift in Sources */,
90A4437E1E91391D00D611FE /* BNDProtocolProxyBase.m in Sources */,
ECC1A6D2207A18DC00AE762C /* NSTableView+DataSource.swift in Sources */,
90A4431E1E9055D200D611FE /* NSSlider.swift in Sources */,
Expand Down Expand Up @@ -1424,6 +1454,7 @@
ECBC51D32161637B00BE80EC /* OrderedCollectionDiff+Strideable+Patch.swift in Sources */,
ECBC51D42161637B00BE80EC /* OrderedCollectionOperation+Strideable+Undo.swift in Sources */,
ECBCE0C82161696B0078E03B /* OrderedCollectionOperation.swift in Sources */,
FCDA45562229C2DE001E0C3D /* CBPeripheral.swift in Sources */,
ECBC51CF2161637B00BE80EC /* ChangesetContainer.swift in Sources */,
90C04DA21E8F0B96000077C8 /* UINavigationBar.swift in Sources */,
9025DCB01F981694007B7689 /* Property+BidirectionalMap.swift in Sources */,
Expand Down Expand Up @@ -1459,6 +1490,7 @@
90A4431D1E9055D200D611FE /* NSSegmentedControl.swift in Sources */,
ECBC51D72161637B00BE80EC /* OrderedCollectionDiff+IndexPath.swift in Sources */,
90A443191E9055D200D611FE /* NSImageView.swift in Sources */,
FCDA45512229C25A001E0C3D /* CBCentralManager.swift in Sources */,
90A4431B1E9055D200D611FE /* NSPopUpButton.swift in Sources */,
90A443211E9055D200D611FE /* NSTextField.swift in Sources */,
EC0D8D3121C69C3C003F8EF2 /* UICollectionView+DataSource.swift in Sources */,
Expand Down
90 changes: 90 additions & 0 deletions Sources/Bond/CoreBluetooth/CBCentralManager.swift
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,90 @@
//
// CBCentralManager.swift
// Bond
//
// Created by Pavlo Naumenko on 3/1/19.
// Copyright © 2019 Swift Bond. All rights reserved.
//

import CoreBluetooth
import ReactiveKit

#if os(iOS) || os(tvOS)

public extension ReactiveExtensions where Base: CBCentralManager {

/// A `ProtocolProxy` for the central manager delegate.
///
/// - Note: Accessing this property for the first time will replace central manager's current delegate
/// with a protocol proxy object (an object that is stored in this property).
/// Current delegate will be used as `forwardTo` delegate of protocol proxy.
public var delegate: ProtocolProxy {
return protocolProxy(for: CBCentralManagerDelegate.self, keyPath: \.delegate)
}

/// A signal that emits central manager state.
///
/// - Note: Uses central manager's `delegate` protocol proxy to observe calls made to `CBCentralManagerDelegate.centralManagerDidUpdateState(_:)` method.
@available(iOS 10.0, *)
public var didUpdateState: SafeSignal<CBManagerState> {
return delegate.signal(for: #selector(CBCentralManagerDelegate.centralManagerDidUpdateState(_:))) { (subject: SafePublishSubject<CBManagerState>, central: CBCentralManager) in
subject.next(central.state)
}
}

/// A signal that emits a dictionary containing information about <i>central</i> that was preserved by the system at the time the app was terminated.
///
/// - Note: Uses central manager's `delegate` protocol proxy to observe calls made to `CBCentralManagerDelegate.centralManager(_:willRestoreState:)` method.
@available(iOS 5.0, *)
public var willRestoreState: SafeSignal<[String : Any]> {
return delegate.signal(for: #selector(CBCentralManagerDelegate.centralManager(_:willRestoreState:))) { (subject: SafePublishSubject<[String : Any]>, central: CBCentralManager, dict: [String : Any]) in
subject.next(dict)
}
}

/// A signal that emits a CBPeripheral object with a dictionary containing any advertisement and scan response data and also current RSSI of peripheral, in dBm.
///
/// - Note: Uses central manager's `delegate` protocol proxy to observe calls made to `CBCentralManagerDelegate.centralManager(_:didDiscover:advertisementData:rssi:)` method.
@available(iOS 5.0, *)
public var didDiscoverPeripheral: SafeSignal<(CBPeripheral, [String : Any], NSNumber)> {
return delegate.signal(for: #selector(CBCentralManagerDelegate.centralManager(_:didDiscover:advertisementData:rssi:))) { (subject: SafePublishSubject<(CBPeripheral, [String : Any], NSNumber)>,
central: CBCentralManager,
peripheral: CBPeripheral,
advertisementData: [String : Any],
RSSI: NSNumber) in
subject.next((peripheral, advertisementData, RSSI))
}
}

/// A signal that emits the CBPeripheral that has connected.
///
/// - Note: Uses central manager's `delegate` protocol proxy to observe calls made to `CBCentralManagerDelegate.centralManager(_:didConnect:)` method.
@available(iOS 5.0, *)
public var didConnectPeripheral: SafeSignal<CBPeripheral> {
return delegate.signal(for: #selector(CBCentralManagerDelegate.centralManager(_:didConnect:))) { (subject: SafePublishSubject<CBPeripheral>, central: CBCentralManager, peripheral: CBPeripheral) in
subject.next(peripheral)
}
}

/// A signal that emits the CBPeripheral that has failed to connect and the cause of the failure.
///
/// - Note: Uses central manager's `delegate` protocol proxy to observe calls made to `CBCentralManagerDelegate.centralManager(_:didFailToConnect:error:)` method.
@available(iOS 5.0, *)
public var didFailToConnectPeripheral: SafeSignal<(CBPeripheral, Error?)> {
return delegate.signal(for: #selector(CBCentralManagerDelegate.centralManager(_:didFailToConnect:error:))) { (subject: SafePublishSubject<(CBPeripheral, Error?)>, central: CBCentralManager, peripheral: CBPeripheral, error: Error?) in
subject.next((peripheral, error))
}
}

/// A signal that emits the CBPeripheral that has disconnected and if an error occurred, the cause of the failure.
///
/// - Note: Uses central manager's `delegate` protocol proxy to observe calls made to `CBCentralManagerDelegate.centralManager(_:didDisconnectPeripheral:error:)` method.
@available(iOS 5.0, *)
public var didDisconnectPeripheral: SafeSignal<(CBPeripheral, Error?)> {
return delegate.signal(for: #selector(CBCentralManagerDelegate.centralManager(_:didDisconnectPeripheral:error:))) { (subject: SafePublishSubject<(CBPeripheral, Error?)>, central: CBCentralManager, peripheral: CBPeripheral, error: Error?) in
subject.next((peripheral, error))
}
}
}

#endif
Loading