Contents

module Faye
  class Server

    class Socket
      def initialize(server, socket, env)
        @server = server
        @socket = socket
        @env    = env
      end

      def send(message)
        @server.pipe_through_extensions(:outgoing, message, @env) do |piped_message|
          @socket.send(Faye.to_json([piped_message])) if @socket
        end
      end

      def close
        @socket.close if @socket
        @socket = nil
      end
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
faye-1.0.4	lib/faye/protocol/socket.rb
faye-1.0.3	lib/faye/protocol/socket.rb
faye-1.0.1	lib/faye/protocol/socket.rb
faye-1.0.0	lib/faye/protocol/socket.rb