code: def _predict_and_stream(
      self, prompt: str
  ) -> Generator[str, None, None]:
      generator = self._client.predict_and_stream(
          str(self._get_parameters(prompt)), api_name=self._API_NAME
      )
      reply_size_so_far = 0
      for response in generator:
          current_reply = self._get_reply(response)
          new_reply_chunk = current_reply[reply_size_so_far:]
          if not new_reply_chunk:
              continue
          reply_size_so_far += len(new_reply_chunk)
          yield new_reply_chunk
  
imports: import abc
  import ast
  import collections
  from typing import Any, AsyncGenerator, Dict, Generator, List, Optional, OrderedDict, Union
  from h2ogpt_client._gradio_client import GradioClientWrapper
  from h2ogpt_client._h2ogpt_enums import DocumentSubset, LangChainAction, LangChainMode, PromptType
  from h2ogpt_client._models import Model
label_desc: Use image node_id 5 for calling the _Completion obj's underlying member method code with example usage: obj._predict_and_stream(prompt) without return types