code: def _clean_cache(self):
      new_ids = set(self.context.request_ids.keys())
      for idx in self.context.kv_cache.keys():
          if idx not in new_ids:
              del self.context.kv_cache[idx]
  
file_path: serve/test/pytest/test_data/streaming/stream_handler.py
imports: import json
  import logging
  import types
  import torch
  from transformers import AutoModelForCausalLM, AutoTokenizer
  from ts.torch_handler.base_handler import BaseHandler
label_desc: Use image node_id 10 for calling the StreamingHandler obj's underlying member method code with example usage: obj._clean_cache() without return types