   }
 
   public func stop() -> Completable {
-    return Completable.create { completable in
+    Completable.create { completable in
       self.queue.async {
         self.portLock.withWriteLock {
           self.portIsValid = false

  }

  public func stop() -> Completable {
    return Completable.create { completable in
      self.queue.async {
        self.messageHandler.syncReplyBody = nil
        self.streamSubject.onCompleted()

        if let portRunLoop = self.portRunLoop {
          CFRunLoopStop(portRunLoop)
        }

        if self.port != nil && CFMessagePortIsValid(self.port) {
          CFMessagePortInvalidate(self.port)

  }

  public func connect(to name: String) -> Completable {
    Completable.create { completable in
      self.queue.async {
        self.portLock.withWriteLock {
          self.port = CFMessagePortCreateRemote(kCFAllocatorDefault, name.cfstr)
