Sha256: bd4983d6dc48fddaa4b37788c9751bd7377c40fbe7fef619ad77b2157229d9ce

Contents?: true

Size: 530 Bytes

Versions: 19

Compression:

Stored size: 530 Bytes

Contents

require 'eventmachine'
require 'bert'

module Envoy

  module Protocol
    include EM::P::ObjectProtocol
    
    module Serializer
      def self.dump(object)
        BERT.encode(object)
      end
      def self.load(data)
        BERT.decode(data)
      end
    end
    
    def serializer
      Serializer
    end
    
    def send_object *args
      super(args.size > 1 ? BERT::Tuple[*args] : args[0])
    end
    
    def receive_object ((command, *args))
      __send__("receive_#{command}", *args)
    end
    
  end

end

Version data entries

19 entries across 19 versions & 1 rubygems

Version Path
envoy-proxy-0.1.1 lib/envoy/protocol.rb
envoy-proxy-0.1.0 lib/envoy/protocol.rb
envoy-proxy-0.0.19 lib/envoy/protocol.rb
envoy-proxy-0.0.18 lib/envoy/protocol.rb
envoy-proxy-0.0.17 lib/envoy/protocol.rb
envoy-proxy-0.0.16 lib/envoy/protocol.rb
envoy-proxy-0.0.15 lib/envoy/protocol.rb
envoy-proxy-0.0.14 lib/envoy/protocol.rb
envoy-proxy-0.0.12 lib/envoy/protocol.rb
envoy-proxy-0.0.11 lib/envoy/protocol.rb
envoy-proxy-0.0.10 lib/envoy/protocol.rb
envoy-proxy-0.0.9 lib/envoy/protocol.rb
envoy-proxy-0.0.8 lib/envoy/protocol.rb
envoy-proxy-0.0.7 lib/envoy/protocol.rb
envoy-proxy-0.0.6 lib/envoy/protocol.rb
envoy-proxy-0.0.5 lib/envoy/protocol.rb
envoy-proxy-0.0.4 lib/envoy/protocol.rb
envoy-proxy-0.0.2 lib/envoy/protocol.rb
envoy-proxy-0.0.1 lib/envoy/protocol.rb