Skip to content

Instantly share code, notes, and snippets.

@deda9
Last active June 18, 2019 08:41
Show Gist options
  • Save deda9/3c8dc73831cdab3823a62ae771e1d453 to your computer and use it in GitHub Desktop.
Save deda9/3c8dc73831cdab3823a62ae771e1d453 to your computer and use it in GitHub Desktop.
Create RxObservable with from
func createRxObservable() {
let source = Observable<Int>.from([1, 2, 3, 4, 6, 7])
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