FeedNextInto For RxSwift

Observable+FeedNextInto

import RxSwift
import Foundation

extension ObservableType {
  
  func feedNextInto(variable: Variable<E>) -> Observable<E> {
    return Observable<E>.create{ observer -> Disposable in
      self.subscribe(
        onNext: {
          variable.value = $0
          observer.onNext($0)
        },
        onError: { observer.onError($0)},
        onCompleted: {observer.onCompleted()}
      )
      return NopDisposable.instance
    }
  }
}
let o = Observable.just(999)
let v = Variable(0)
let db = DisposeBag()


v.asObservable()
  .subscribeNext{print ("Variable Value: \($0)")}

o
  .feedNextInto(v)
  .subscribeCompleted{print ("Observable: Completed")}