                       withDiscoveryInfo info: [String: String]?) {
     // Get a unique list of peers
     var result: [(MCPeerID, [String: String]?)] = []
-    for o in (self.rx_nearbyPeers.value + [(peerId, info)]) {
+    for o in (self._nearbyPeers.value + [(peerId, info)]) {
       if (result.map { $0.0 }).indexOf(o.0) == nil {
         result = result + [o]
       }
     }
 
-    self.rx_nearbyPeers.value = result
+    self._nearbyPeers.value = result
   }
 
   public func browser(browser: MCNearbyServiceBrowser,
                       lostPeer peerId: MCPeerID) {
-    self.rx_nearbyPeers.value = self.rx_nearbyPeers.value.filter { (id, _) in
+    self._nearbyPeers.value = self._nearbyPeers.value.filter { (id, _) in
       id != peerId
     }
   }
 
   public func browser(browser: MCNearbyServiceBrowser,
                       didNotStartBrowsingForPeers err: NSError) {
-    rx_connectionErrors.on(.Next(err))
+    _connectionErrors.on(.Next(err))
   }
 
 }

    advertiser.stopAdvertisingPeer()
  }

  let rx_connections = Variable<[MCPeerID]>([])

  public func connections() -> Observable<[MCPeerID]> {
    return rx_connections.asObservable()
  }

  let rx_nearbyPeers: Variable<[(MCPeerID, [String: String]?)]> = Variable([])

  public func nearbyPeers() -> Observable<[(MCPeerID, [String: String]?)]> {
    return rx_nearbyPeers.asObservable()
  }

  public func startBrowsing() {

    maxLength: Int = 512)
    -> Observable<[UInt8]> {

    return _receivedStreams
      .filter { (c, n, _) in c == other && n == streamName }
      .map { $2 }
      .map { (stream) in
