class Protobuf::Rpc::SocketServer

def cleanup? 
  # every 10 connections run a cleanup routine after closing the response
  @threads.size > (@thread_threshold - 1) && (@threads.size % @thread_threshold) == 0
end