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


  fileprivate var syncReplyBody: RxMessagePortServer.SyncReplyBody?

  fileprivate init(subject: PublishSubject<RxMessagePortServer.Message>) {
    self.subject = subject
  }

  fileprivate func handleMessage(
    msgId: Int32,

  }

  public var syncReplyBody: SyncReplyBody? {
    get { self.messageHandler.syncReplyBody }
    set { self.messageHandler.syncReplyBody = newValue }
  }

  public var stream: Observable<Message> { self.streamSubject.asObservable() }

  public var queue = DispatchQueue(
    label: String(reflecting: RxMessagePortServer.self),
    qos: .userInitiated
  )

  public init() { self.messageHandler = MessageHandler(subject: self.streamSubject) }

  public func run(as name: String) -> Completable {
    Completable.create { completable in
      self.queue.async {
        var localCtx = CFMessagePortContext(
          version: 0,
