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