Sha256: 2a7a103e32ba46d664d03985cbb8d0b2c192adebbcab0518fdad6813ce8823cd
Contents?: true
Size: 681 Bytes
Versions: 8
Compression:
Stored size: 681 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
module Jobs
# Job that runs the eofed operation when we receive eof without messages alongside.
class Eofed < Base
# @param executor [Karafka::Processing::Executor] executor that is suppose to run the job
# @return [Eofed]
def initialize(executor)
@executor = executor
super()
end
# Runs code prior to scheduling this eofed job
def before_schedule
executor.before_schedule_eofed
end
# Runs the eofed job via an executor.
def call
executor.eofed
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems