# File lib/faye/eventsource.rb, line 99
    def initialize(event_source)
      @event_source = event_source
      @connection   = event_source.env['em.connection']
      @stream_send  = event_source.env['stream.send']

      @connection.socket_stream = self if @connection.respond_to?(:socket_stream)
    end