File tree 1 file changed +8
-8
lines changed 1 file changed +8
-8
lines changed Original file line number Diff line number Diff line change 104
104
105
105
r . close
106
106
107
- expect ( read_task . wait ) . to be == ' closed stream'
107
+ expect ( read_task . wait ) . to be == " closed stream"
108
108
end
109
109
110
110
it "can interrupt reading fiber when closing from another fiber" do
122
122
end
123
123
124
124
close_task . wait
125
- expect ( read_task . wait ) . to be == ' closed stream'
125
+ expect ( read_task . wait ) . to be == " closed stream"
126
126
end
127
127
128
128
it "can interrupt reading fiber when closing from a new thread" do
140
140
end
141
141
142
142
close_thread . value
143
- expect ( read_task . wait ) . to be == ' closed stream'
143
+ expect ( read_task . wait ) . to be == " closed stream"
144
144
end
145
145
146
146
it "can interrupt reading fiber when closing from a fiber in a new thread" do
161
161
end
162
162
163
163
close_thread . value
164
- expect ( read_task . wait ) . to be == ' closed stream'
164
+ expect ( read_task . wait ) . to be == " closed stream"
165
165
end
166
166
167
167
it "can interrupt reading thread when closing from a fiber" do
176
176
end
177
177
178
178
# Wait until read_thread blocks on I/O
179
- while read_thread . status != ' sleep'
179
+ while read_thread . status != " sleep"
180
180
sleep ( 0.001 )
181
181
end
182
182
185
185
end
186
186
187
187
close_task . wait
188
- expect ( read_thread . value ) . to be == ' closed stream'
188
+ expect ( read_thread . value ) . to be == " closed stream"
189
189
end
190
190
191
191
it "can interrupt reading fiber in a new thread when closing from a fiber" do
203
203
end
204
204
205
205
# Wait until read_thread blocks on I/O
206
- while read_thread . status != ' sleep'
206
+ while read_thread . status != " sleep"
207
207
sleep ( 0.001 )
208
208
end
209
209
212
212
end
213
213
close_task . wait
214
214
215
- expect ( read_thread . value ) . to be == ' closed stream'
215
+ expect ( read_thread . value ) . to be == " closed stream"
216
216
end
217
217
end
218
218
end
You can’t perform that action at this time.
0 commit comments