class Reacto::Operations::FlatMapLatest
Public Class Methods
new(transform)
click to toggle source
# File lib/reacto/operations/flat_map_latest.rb, line 6 def initialize(transform) @transform = transform @last_active = nil end
Public Instance Methods
call(tracker)
click to toggle source
# File lib/reacto/operations/flat_map_latest.rb, line 11 def call(tracker) subscription = Subscriptions::FlatMapSubscription.new(tracker) value = lambda do |v| trackable = @transform.call(v) @last_active.unsubscribe if @last_active sub = subscription.subscription! trackable.do_track sub @last_active = sub end close = lambda do subscription.source_closed = true return unless subscription.closed? tracker.on_close end Subscriptions::OperationSubscription.new( tracker, value: value, close: close ) end