class Reacto::Operations::FlatMap
Public Class Methods
new(transform)
click to toggle source
# File lib/reacto/operations/flat_map.rb, line 7 def initialize(transform) @transform = transform end
Public Instance Methods
call(tracker)
click to toggle source
# File lib/reacto/operations/flat_map.rb, line 11 def call(tracker) subscription = Subscriptions::FlatMapSubscription.new(tracker) value = ->(v) do trackable = @transform.call(v) trackable.do_track subscription.subscription! end close = ->() do subscription.source_closed = true return unless subscription.closed? tracker.on_close end Subscriptions::OperationSubscription.new( tracker, value: value, close: close ) end