class Reacto::Operations::Last
Public Class Methods
new()
click to toggle source
# File lib/reacto/operations/last.rb, line 6 def initialize @marker = {} @prev = @marker end
Public Instance Methods
call(tracker)
click to toggle source
# File lib/reacto/operations/last.rb, line 11 def call(tracker) close = lambda do tracker.on_value(@prev) if @prev != @marker tracker.on_close end error = lambda do |e| tracker.on_value(@prev) if @prev != @marker tracker.on_error(e) end Subscriptions::OperationSubscription.new( tracker, value: -> (v) { @prev = v }, error: error, close: close ) end