Contents

require 'lifx/observable'

module LIFX
  # @api private
  module TransportManager
    class Base
      include Logging
      include Observable
      attr_accessor :context

      def initialize(**args)
      end

      def discover
        raise NotImplementedError
      end

      def write(message)
        raise NotImplementedError
      end

      def flush(**options)
        raise NotImplementedError
      end

      def stop
        @context = nil
        remove_observers
      end

      def observer_callback_definition
        {
          message_received: -> (message: nil, ip: nil, transport: nil) {}
        }
      end
    end
  end
end

require 'lifx/transport_manager/lan'

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
lifx-0.4.8	lib/lifx/transport_manager.rb