Contents

require 'eventmachine'

module Azure
  module ServiceRuntime
    class GoalStatePipeMonitor < EM::Connection

      # Public: Initializes a new monitor.
      #
      # callback - a lambda to invoke when a new message arraives
      def initialize(new_message_callback)
        @new_message_callback = new_message_callback
      end

      def notify_readable
        state_message = GoalStateProtocol.read_message(@io)
        @new_message_callback.call(state_message)
      end
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
azure-0.1.1	lib/azure/service_runtime/client/goal_state_pipe_monitor.rb
azure-0.1.0	lib/azure/service_runtime/client/goal_state_pipe_monitor.rb