lib/isomorfeus/transport.rb in isomorfeus-transport-23.7.0.rc4 vs lib/isomorfeus/transport.rb in isomorfeus-transport-23.7.0.rc5
- old
+ new
@@ -113,9 +113,11 @@
Isomorfeus::Transport::RequestAgent.new(request)
end
unless agent.queued || agent.sent
agent.queued = true
register_request_in_progress(request, agent.id)
+ end
+ unless agent.sent
begin
Isomorfeus.raise_error(message: 'No socket!') unless @socket
@socket.send(JSON.dump({request: { agent_ids: { agent.id => request }}}))
agent.sent = true
after(20000) do