class TelegramWorkflow::Updates

Attributes

stop[W]

Public Class Methods

new(params) click to toggle source
# File lib/telegram_workflow/updates.rb, line 4
def initialize(params)
  @params = params
end

Public Instance Methods

enum() click to toggle source
# File lib/telegram_workflow/updates.rb, line 8
def enum
  Enumerator.new do |y|
    loop do
      break if @stop

      updates = TelegramWorkflow::Client.new.get_updates(@params)["result"]
      updates.each do |update|
        y << update
      end

      if updates.any?
        @params.merge! offset: updates.last["update_id"] + 1
      end
    end
  end
end