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