Sha256: bbcf17dc4c6fad5e5657b2d008b7385575b7e7a17f8f25bf6f7e740443d8ae53
Contents?: true
Size: 1.01 KB
Versions: 14
Compression:
Stored size: 1.01 KB
Contents
module PgEventstore
class BasicRunner
include PgEventstore::Extensions::CallbacksExtension
extend Forwardable
# _@param_ `run_interval` — seconds. Determines how often to run async task. Async task is determined by :after_runner_stopped callback
#
# _@param_ `async_shutdown_time` — seconds. Determines how long to wait for the async shutdown to wait for the runner to finish.
%a{rbs:test:skip} def initialize: ((Integer | Float) run_interval, (Integer | Float) async_shutdown_time) -> void
def start: () -> self
def stop: () -> self
def stop_async: () -> self
def restore: () -> self
def wait_for_finish: () -> self
def state: () -> String
# _@param_ `state`
def within_state: (Symbol state) { () -> untyped } -> untyped
def synchronize: () { () -> untyped } -> untyped
def _start: () -> void
def delegate_change_state_cbx: () -> void
# _@param_ `state`
def change_state: (String state) -> void
def define_callback: () -> void
end
end
Version data entries
14 entries across 14 versions & 1 rubygems