class Aggro::ZeroMQTransport::Server::Workload

Private: Struct to hold request workload data.

Public Instance Methods

finish(reply) click to toggle source
# File lib/aggro/zeromq_transport/server.rb, line 9
def finish(reply)
  mutex.synchronize do
    socket.send_string identity, ZMQ::SNDMORE
    socket.send_string '', ZMQ::SNDMORE
    socket.send_string reply.to_s
  end
end