       json = nil
     }
 
-    rx_incomingConnections.on(.Next(
+    _incomingConnections.on(.Next(
       peerID,
       json as? [String: AnyObject],
       invitationHandler

    // 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 = []
  }

  public func connect(peer: MCPeerID, context: [String: AnyObject]?, timeout: NSTimeInterval) {

  public func session(session: MCSession,
                      peer peerID: MCPeerID,
                      didChangeState state: MCSessionState) {
    _connections.value = session.connectedPeers
    switch state {
    case .Connected: _connectedPeer.on(.Next(peerID))
    // Called for failed connections as well, but we'll allow for that.
    case .NotConnected: _disconnectedPeer.on(.Next(peerID))
    default: break
    }
  }
