Contents

module LucidChannel
  module Mixin
    def self.included(base)
      base.instance_exec do
        def process_message(message)
          if @message_processor
            @message_processor.call(message)
          else
            puts "#{self} received: #{message}, but no processor defined!"
          end
        end

        def on_message(&block)
          @message_processor = block
        end

        def send_message(message)
          Isomorfeus::Transport.send_notification(self, message)
        end

        def subscribe
          Isomorfeus::Transport.subscribe(self)
        end

        def unsubscribe
          Isomorfeus::Transport.unsubscribe(self)
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
isomorfeus-transport-1.0.0.delta8	lib/lucid_channel/mixin.rb
isomorfeus-transport-1.0.0.delta7	lib/lucid_channel/mixin.rb