Sha256: f1de44c1c1f7502860c50e3d2bee4aabdabb295fc66535915bd9831846a666bd

Contents?: true

Size: 663 Bytes

Versions: 7

Compression:

Stored size: 663 Bytes

Contents

module Isomorfeus
  module Transport
    class ServerSocketProcessor
      include Isomorfeus::Transport::ServerProcessor

      def initialize(session_id, user)
        @session_id = session_id
        @user = user
      end

      def on_message(client, data)
        request_hash = Oj.load(data, mode: :strict)
        result = process_request(client, @session_id, @user, request_hash)
        client.write Oj.dump(result, mode: :strict)
      end

      def on_close(client)
        # nothing for now
      end

      def on_open(client)
        # nothing for now
      end

      def on_shutdown(client)
        # nothing for now
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
isomorfeus-transport-1.0.0.epsilon1 lib/isomorfeus/transport/server_socket_processor.rb
isomorfeus-transport-1.0.0.delta12 lib/isomorfeus/transport/server_socket_processor.rb
isomorfeus-transport-1.0.0.delta11 lib/isomorfeus/transport/server_socket_processor.rb
isomorfeus-transport-1.0.0.delta10 lib/isomorfeus/transport/server_socket_processor.rb
isomorfeus-transport-1.0.0.delta9 lib/isomorfeus/transport/server_socket_processor.rb
isomorfeus-transport-1.0.0.delta8 lib/isomorfeus/transport/server_socket_processor.rb
isomorfeus-transport-1.0.0.delta7 lib/isomorfeus/transport/server_socket_processor.rb