Skip to content

Commit 02f0b95

Browse files
authored
Merge pull request #187 from SciRuby/fix_ffirzmq_adapter
Fix FfirzmqAdapter
2 parents c02d403 + 36a499c commit 02f0b95

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

lib/iruby/session_adapter/ffirzmq_adapter.rb

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,26 @@ def self.load_requirements
55
require 'ffi-rzmq'
66
end
77

8+
def send(sock, data)
9+
data.each_with_index do |part, i|
10+
sock.send_string(part, i == data.size - 1 ? 0 : ZMQ::SNDMORE)
11+
end
12+
end
13+
14+
def recv(sock)
15+
msg = []
16+
while msg.empty? || sock.more_parts?
17+
begin
18+
frame = ''
19+
rc = sock.recv_string(frame)
20+
ZMQ::Util.error_check('zmq_msg_recv', rc)
21+
msg << frame
22+
rescue
23+
end
24+
end
25+
msg
26+
end
27+
828
def heartbeat_loop(sock)
929
@heartbeat_device = ZMQ::Device.new(sock, sock)
1030
end

0 commit comments

Comments
 (0)