spec/neovim/async_session_spec.rb in neovim-0.0.6 vs spec/neovim/async_session_spec.rb in neovim-0.1.0

@@ -7,14 +7,15 @@
         stream = MsgpackStream.new(event_loop)
         async_session = AsyncSession.new(stream)
 
         server_thread = Thread.new do
           client = server.accept
-          IO.select(nil, [client])
-          client.write(MessagePack.pack(
-            [0, 123, "func", [1, 2, 3]]
-          ))
+          client.write(
+            MessagePack.pack(
+              [0, 123, "func", [1, 2, 3]]
+            )
+          )
         end
 
         request = nil
         async_session.run do |msg|
           request = msg
@@ -32,14 +33,15 @@
         stream = MsgpackStream.new(event_loop)
         async_session = AsyncSession.new(stream)
 
         server_thread = Thread.new do
           client = server.accept
-          IO.select(nil, [client])
-          client.write(MessagePack.pack(
-            [2, "func", [1, 2, 3]]
-          ))
+          client.write(
+            MessagePack.pack(
+              [2, "func", [1, 2, 3]]
+            )
+          )
         end
 
         notification = nil
         async_session.run do |message|
           notification = message
@@ -54,19 +56,21 @@
       end
 
       it "receives responses to requests" do
         stream = MsgpackStream.new(event_loop)
         async_session = AsyncSession.new(stream)
-        messages = []
+        request = nil
 
         server_thread = Thread.new do
           client = server.accept
-          messages << client.readpartial(1024)
+          request = client.readpartial(1024)
 
-          client.write(MessagePack.pack(
-            [1, 0, [0, "error"], "result"]
-          ))
+          client.write(
+            MessagePack.pack(
+              [1, 0, [0, "error"], "result"]
+            )
+          )
         end
 
         error, result = nil
         async_session.request("func", 1, 2, 3) do |err, res|
           error, result = err, res
@@ -77,11 +81,11 @@
         expect(result).to eq("result")
 
         server_thread.join
         async_session.shutdown
 
-        expect(messages).to eq(
-          [MessagePack.pack([0, 0, "func", [1, 2, 3]])]
+        expect(request).to eq(
+          MessagePack.pack([0, 0, "func", [1, 2, 3]])
         )
       end
     end
 
     context "tcp" do