gistfile1.txt

    private let realm = try! Realm()
    
    func save(customObject: CustomObject) -> Observable<Bool> {
        return create({ (observer) -> Disposable in
            do {
                try self.realm.write {
                    self.realm.add(customObject, update: true)
                    observer.onNext(true)
                }
            } catch {
                observer.onError(NSError(domai...)
            }
            observer.onCompleted()  //I'm not sure why you put this in "Some other condition", isnt supposed to be called after .onNext or .onError ?
            return AnonymousDisposable {
            }
        })
    }

    private let realm = try! Realm()

    func save(customObject: CustomObject) -> Observable<Bool> {
        return create({ (observer) -> Disposable in
            do {
                try self.realm.write {
                    self.realm.add(customObject, update: true)
                    observer.onNext(true)
                    observer.onCompleted() // call it here if you are done (it will call onCompleted callback on subscriptions if it exists and dispose Disposable)
                }
            } catch {
                observer.onError(NSError(domai...)
            }
            return AnonymousDisposable {
            }
        })
    }