blob: 1a5cfcac6ba51f936c8ff90f0dad00693cbfdd6b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
# require[_relative] doesn't like non .rb/.so/.a extensions in MRI
load File.expand_path('./observable.mrb', __dir__)
empty = Observable.create { |observer| observer.complete }
value = -> (v) { Observable.create { |observer| observer.next(v) } }
failure = Observable.create { |observer| observer.error("some error") }
subscriptions = {
next: -> (x) { puts "next: '#{x}'" },
error: -> (x) { puts "error: '#{x}'" },
complete: -> () { puts "complete" }
}
empty.subscribe(subscriptions)
value.("hello world").subscribe(subscriptions)
value.("hello world").subscribe { |x| puts "block based subscription: '#{x}'" }
value.(2).map { |x| x + 1 } .subscribe(subscriptions)
failure.subscribe(subscriptions)
failure # prints nothing, observables are lazy!
# output will be:
# complete
# next: 'hello world'
# block based sub hello world
# next: '3'
# error: 'some error'
|
