     // Because we are aggregating found and lost peers in order
     // to get nearby peers, we should start with a clean slate when
     // browsing is kicked off again.
-    rx_nearbyPeers.value = []
+    _nearbyPeers.value = []
   }
 
   public func connect(peer: MCPeerID, context: [String: AnyObject]?, timeout: NSTimeInterval) {

  public func session(session: MCSession,
                      didReceiveData data: NSData,
                      fromPeer peerID: MCPeerID) {
    rx_data.on(.Next(peerID, data))
  }

  public func session(session: MCSession,
                      didStartReceivingResourceWithName name: String,
                      fromPeer peerID: MCPeerID,
                      withProgress progress: NSProgress) {
    rx_resource.on(.Next(peerID, name, .Progress(progress)))
  }

  public func session(session: MCSession,

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

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