File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -17,7 +17,7 @@ class SocketCacheTest < Test::Unit::TestCase
17
17
assert_equal ( socket , c . checkout_or ( 'key' ) { socket } )
18
18
c . checkin ( socket )
19
19
20
- sock = dont_allow ( mock! ) . open
20
+ sock = mock! . open . never . subject
21
21
assert_equal ( socket , c . checkout_or ( 'key' ) { sock . open } )
22
22
end
23
23
@@ -130,7 +130,7 @@ def teardown
130
130
131
131
c = Fluent ::Plugin ::ForwardOutput ::SocketCache . new ( 10 , $log)
132
132
sock = mock! . close { 'closed' } . subject
133
- sock2 = dont_allow ( mock! ) . close
133
+ sock2 = mock! . close . never . subject
134
134
stub ( sock ) . inspect
135
135
stub ( sock2 ) . inspect
136
136
@@ -154,7 +154,7 @@ def teardown
154
154
Timecop . freeze ( Time . parse ( '2016-04-13 14:00:00 +0900' ) )
155
155
156
156
c = Fluent ::Plugin ::ForwardOutput ::SocketCache . new ( 10 , $log)
157
- sock = dont_allow ( mock! ) . close
157
+ sock = mock! . close . never . subject
158
158
stub ( sock ) . inspect
159
159
c . checkout_or ( 'key' ) { sock }
160
160
Original file line number Diff line number Diff line change @@ -175,7 +175,7 @@ def event_router
175
175
test "don't call default collector when tag matched" do
176
176
event_router . add_rule ( 'test' , output )
177
177
assert_rr do
178
- dont_allow ( default_collector ) . emit_events ( 'test' , is_a ( OneEventStream ) )
178
+ mock ( default_collector ) . emit_events ( 'test' , is_a ( OneEventStream ) ) . never
179
179
event_router . emit ( 'test' , Engine . now , 'k' => 'v' )
180
180
end
181
181
# check emit handler doesn't catch rr error
@@ -201,7 +201,7 @@ def filter_stream(_tag, es); end
201
201
event_router . add_rule ( 'test' , filter )
202
202
203
203
assert_rr do
204
- dont_allow ( filter ) . filter_stream ( 'test' , is_a ( OneEventStream ) ) { events }
204
+ mock ( filter ) . filter_stream ( 'test' , is_a ( OneEventStream ) ) . never
205
205
event_router . emit ( 'foo' , Engine . now , 'k' => 'v' )
206
206
end
207
207
end
You can’t perform that action at this time.
0 commit comments