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 b8bfb62 commit d97779cCopy full SHA for d97779c
test/publish_subscribe_test.rb
@@ -191,7 +191,7 @@ def test_unsubscribe_without_a_subscribe
191
def test_subscribe_past_a_timeout
192
# For some reason, a thread here doesn't reproduce the issue.
193
sleep = %{sleep #{OPTIONS[:timeout] * 2}}
194
- publish = %{echo "publish foo bar\r\n" | nc 127.0.0.1 #{OPTIONS[:port]}}
+ publish = %{ruby -rsocket -e 't=TCPSocket.new("127.0.0.1",#{OPTIONS[:port]});t.write("publish foo bar\\r\\n");t.read(4);t.close'}
195
cmd = [sleep, publish].join("; ")
196
197
IO.popen(cmd, "r+") do |pipe|
0 commit comments