Pass proxy to streaming EventSource

dlau · dlau · commit 202d136acda6 · 2017-05-08T13:00:35.000-07:00
diff --git a/lib/ldclient-rb/config.rb b/lib/ldclient-rb/config.rb
@@ -145,7 +145,7 @@ def offline?
     attr_reader :feature_store
 
     
-    # The proxy configuration
+    # The proxy configuration string
     #
     attr_reader :proxy
 
diff --git a/lib/ldclient-rb/stream.rb b/lib/ldclient-rb/stream.rb
@@ -33,7 +33,7 @@ def start
         'Authorization' => @sdk_key,
         'User-Agent' => 'RubyClient/' + LaunchDarkly::VERSION
       }
-      opts = {:headers => headers, :with_credentials => true}
+      opts = {:headers => headers, :with_credentials => true, :proxy => @config.proxy}
       @es = Celluloid::EventSource.new(@config.stream_uri + "/flags", opts) do |conn|
         conn.on(PUT) { |message| process_message(message, PUT) }
         conn.on(PATCH) { |message| process_message(message, PATCH) }

Original file line number	Diff line number	Diff line change
`@@ -145,7 +145,7 @@ def offline?`
`145`	`145`	`attr_reader :feature_store`
`146`	`146`
`147`	`147`
`148`		`- # The proxy configuration`
	`148`	`+ # The proxy configuration string`
`149`	`149`	`#`
`150`	`150`	`attr_reader :proxy`
`151`	`151`
Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ def start`
`33`	`33`	`'Authorization' => @sdk_key,`
`34`	`34`	`'User-Agent' => 'RubyClient/' + LaunchDarkly::VERSION`
`35`	`35`	`}`
`36`		`- opts = {:headers => headers, :with_credentials => true}`
	`36`	`+ opts = {:headers => headers, :with_credentials => true, :proxy => @config.proxy}`
`37`	`37`	`@es = Celluloid::EventSource.new(@config.stream_uri + "/flags", opts) do \|conn\|`
`38`	`38`	`conn.on(PUT) { \|message\| process_message(message, PUT) }`
`39`	`39`	`conn.on(PATCH) { \|message\| process_message(message, PATCH) }`