class Liebre::Actor::Publisher
Attributes
context[R]
Public Class Methods
new(context)
click to toggle source
Calls superclass method
# File lib/liebre/actor/publisher.rb, line 12 def initialize context super() @context = context end
Public Instance Methods
__clean__()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 36 def __clean__ reporter.on_clean { core.clean() } end
__publish__(payload, opts)
click to toggle source
# File lib/liebre/actor/publisher.rb, line 32 def __publish__ payload, opts reporter.on_publish { core.publish(payload, opts) } end
__start__()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 25 def __start__ reporter.on_start { core.start } end
__stop__()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 28 def __stop__ reporter.on_stop { core.stop } end
clean()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 23 def clean() async.__clean__(); end
publish(payload, opts = {})
click to toggle source
# File lib/liebre/actor/publisher.rb, line 21 def publish(payload, opts = {}) async.__publish__(payload, opts); end
start()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 18 def start() async.__start__(); end
stop()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 19 def stop() async.__stop__(); end
Private Instance Methods
core()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 42 def core @core ||= Core.new(resources, context) end
reporter()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 50 def reporter @reporter ||= Reporter.new(context) end
resources()
click to toggle source
# File lib/liebre/actor/publisher.rb, line 46 def resources Resources.new(context) end