We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb9895d commit fa25549Copy full SHA for fa25549
spec/mongo/server/connection_spec.rb
@@ -323,11 +323,11 @@
323
it "closes the socket and does not use it for subsequent requests" do
324
t = Thread.new {
325
# Kill the thread just before the reply is read
326
- allow(Mongo::Protocol::Reply).to receive(:deserialize) { t.kill }
+ allow(Mongo::Protocol::Reply).to receive(:deserialize_header) { t.kill }
327
connection.dispatch([ query_bob ])
328
}
329
- t.join(2)
330
- allow(Mongo::Protocol::Reply).to receive(:deserialize).and_call_original
+ t.join
+ allow(Mongo::Protocol::Reply).to receive(:deserialize_header).and_call_original
331
expect(connection.dispatch([ query_alice ]).documents.first['name']).to eq('alice')
332
end
333
0 commit comments