Contents

module PbActor
  module Message
    class << self
      def send msg, wr
        Marshal.dump(msg, wr)
      rescue Errno::EPIPE => e
        raise DeadActorError, 'dead actor call'
      end

      def recv rd
        Marshal.load rd
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pb_actor-0.0.3	lib/pb_actor/message.rb