class Protobuf::Rpc::Zmq::Worker

def run
  while ::Protobuf::Rpc::Zmq::Server.running? do
    # poll for 1_000 milliseconds then continue looping
    # This lets us see whether we need to die
    @poller.poll(1_000)
    @poller.readables.each do |socket|
      initialize_request!
      handle_request(socket)
      handle_client unless @request_data.nil?
    end
  end
ensure
  @socket.close
  @zmq_context.terminate
end