import NRxSwift
import RxSwift

NKObservable.nk_just(1)

NKObservable.nk_error(Error.SomeErrorType)

NKObservable.nk_create { (observer) in
            observer.nk_setValue("Success")
        }

validateObservable.nk_continueWithSuccessCloure { (element) -> Observable<NKResult> in
            return postMessageObservable
        }.nk_continueWithCloure { (element) -> Observable<NKResult> in
            return resetSomeStuffsObservable
        }.subscribeNext { (result) in 
            // the error will be handled in this closure, not subscribeError anymore
            // do something
        }.addDisposableTo(self.disposeBag)