@@ -29,7 +29,7 @@ def with_client(client)
29
29
"Authorization" => "secret"
30
30
}
31
31
32
- with_client ( subject . new ( server . base_uri , headers : headers , logger : NullLogger . new ) ) do |client |
32
+ with_client ( subject . new ( server . base_uri , headers : headers ) ) do |client |
33
33
received_req = requests . pop
34
34
expect ( received_req . header ) . to eq ( {
35
35
"accept" => [ "text/event-stream" ] ,
@@ -59,7 +59,7 @@ def with_client(client)
59
59
end
60
60
61
61
event_sink = Queue . new
62
- client = subject . new ( server . base_uri , logger : NullLogger . new ) do |c |
62
+ client = subject . new ( server . base_uri ) do |c |
63
63
c . on_event { |event | event_sink << event }
64
64
end
65
65
@@ -93,8 +93,7 @@ def with_client(client)
93
93
94
94
event_sink = Queue . new
95
95
error_sink = Queue . new
96
- client = subject . new ( server . base_uri ,
97
- reconnect_time : 0.25 , logger : NullLogger . new ) do |c |
96
+ client = subject . new ( server . base_uri , reconnect_time : 0.25 ) do |c |
98
97
c . on_event { |event | event_sink << event }
99
98
c . on_error { |error | error_sink << error }
100
99
end
@@ -127,7 +126,7 @@ def with_client(client)
127
126
128
127
event_sink = Queue . new
129
128
client = subject . new ( server . base_uri ,
130
- reconnect_time : 0.25 , read_timeout : 0.25 , logger : NullLogger . new ) do |c |
129
+ reconnect_time : 0.25 , read_timeout : 0.25 ) do |c |
131
130
c . on_event { |event | event_sink << event }
132
131
end
133
132
0 commit comments