Skip to content

Commit ceaa157

Browse files
committed
clean up example
1 parent ac0ce5d commit ceaa157

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

04-reqres/example-reqrep.rb

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,7 @@
66

77
$port = 2200
88

9-
# server
10-
thread do
9+
thread do # server
1110
ctx = ZMQ::Context.new
1211
rep = ctx.socket(ZMQ::REP)
1312
rep.bind( "tcp://127.0.0.1:#{$port}" )
@@ -21,13 +20,15 @@
2120
end
2221
end
2322

24-
# client
25-
thread do
23+
thread do # client
2624
ctx = ZMQ::Context.new
2725
req = ctx.socket(ZMQ::REQ)
2826
req.connect( "tcp://127.0.0.1:#{$port}" )
2927
req.send( "put foo bar" )
3028
puts req.recv
29+
sleep 1
30+
puts req.send( "put foo2 bar2" ) && req.recv
31+
exit!
3132
end
3233

3334
join_threads

0 commit comments

Comments
 (0)