# 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