Skip to content

Instantly share code, notes, and snippets.

@deda9
Last active June 18, 2019 08:49
Show Gist options
  • Save deda9/e71033e663dea21a6908e62539df5d62 to your computer and use it in GitHub Desktop.
Save deda9/e71033e663dea21a6908e62539df5d62 to your computer and use it in GitHub Desktop.
Create RxObservable with range
func createRxObservable() {
let source: Observable<Int> = Observable.range(start: 3, count: 3)
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