File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -30,10 +30,10 @@ def initialize(opts = {})
3030 @flush_interval = opts [ :flush_interval ] || Config . default_flush_interval
3131 @connect_timeout = opts [ :connect_timeout ] || Config . default_connect_timeout
3232 @read_timeout = opts [ :read_timeout ] || Config . default_read_timeout
33- @log_timings = opts [ :log_timings ] || Config . default_log_timings
34- @stream = opts [ :stream ] || Config . default_stream
3533 @feature_store = opts [ :feature_store ] || Config . default_feature_store
36- @debug_stream = opts [ :debug_stream ] || Config . default_debug_stream
34+ @stream = opts . has_key? ( :stream ) ? opts [ :stream ] : Config . default_stream
35+ @log_timings = opts . has_key? ( :log_timings ) ? opts [ :log_timings ] : Config . default_log_timings
36+ @debug_stream = opts . has_key? ( :debug_stream ) ? opts [ :debug_stream ] : Config . default_debug_stream
3737 end
3838
3939 #
You can’t perform that action at this time.
0 commit comments