     return session.connectionErrors()
   }
 
-  public func connectionErrors(cb: (NSError) -> ()) {
-    connectionErrors()
-    .subscribeNext(cb)
-    .addDisposableTo(disposeBag)
-  }
-
   // Sending Data
 
   public func send

    .map { (Client(iden: $0), $1, $2.fromFinished()!) }
  }

  public func receive(cb: (Client<I>, String, NSURL) -> ()) {
    receive()
    .subscribeNext(cb)
    .addDisposableTo(disposeBag)
  }

  deinit {
    self.disconnect()

    .merge()
  }

  public func receive() -> Observable<(Client<I>, String)> {
    return session.receive()
    .map { (Client(iden: $0), NSString(data: $1, encoding: NSUTF8StringEncoding)) }
