docstr: Test the streaming interface to the Pipeline 
docstr_tok: ["Test","the","streaming","interface","to","the","Pipeline"]
code: def test_stream(self, pipeline):
      """Test the streaming interface to the Pipeline"""
      # Test all of the documents in one batch
      # (the default batch size is significantly more than |EN_DOCS|)
      processed = [doc for doc in pipeline.stream(EN_DOCS)]
      assert (
          "\n\n".join(["{:C}".format(doc) for doc in processed])
          == EN_DOC_CONLLU_GOLD_MULTIDOC
      )
  
      # It should also work on an iterator rather than an iterable
      processed = [doc for doc in pipeline.stream(iter(EN_DOCS))]
      assert (
          "\n\n".join(["{:C}".format(doc) for doc in processed])
          == EN_DOC_CONLLU_GOLD_MULTIDOC
      )
  
      # Stream one at a time
      processed = [
          doc for doc in pipeline.stream(EN_DOCS, batch_size=1)
      ]
      processed = ["{:C}".format(doc) for doc in processed]
      assert "\n\n".join(processed) == EN_DOC_CONLLU_GOLD_MULTIDOC
  
imports: import pytest
  import stanza
  from stanza.utils.conll import CoNLL
  from stanza.models.common.doc import Document
  from stanza.tests import *
  from stanza.tests.pipeline.pipeline_device_tests import check_on_gpu, check_on_cpu
label_desc: Use image node_id 11 for calling the TestEnglishPipeline obj's underlying member method code with example usage: obj.test_stream(pipeline) without return types