Skip to content

Instantly share code, notes, and snippets.

@deda9
Created June 18, 2019 08:46
Show Gist options
  • Save deda9/e2e02f2b54323d7e1a90ae26ae21b2b8 to your computer and use it in GitHub Desktop.
Save deda9/e2e02f2b54323d7e1a90ae26ae21b2b8 to your computer and use it in GitHub Desktop.
Create RxObservable with Just
func createRxObservable() {
let source: Observable<Int> = Observable.just(1)
source
.subscribe(onNext: { number in
print("Current emitted number: ", number)
}, onError: { _ in print("On Error") },
onCompleted: { print("Complete") },
onDisposed: nil)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment