class Flatware::Sink::Client

Public Class Methods

new(sink_endpoint) click to toggle source
# File lib/flatware/sink/client.rb, line 10
def initialize(sink_endpoint)
  @sink = DRbObject.new_with_uri sink_endpoint
end

Private Instance Methods

push(message) click to toggle source
# File lib/flatware/sink/client.rb, line 22
def push(message)
  @sink.public_send message
end