code: def org_stream(ctx, organization, github_url, github_token, clone_dir,
                 verbose, filter, exclude, stream_uri, assume):
      
      logging.basicConfig(
          format="%(asctime)s: %(name)s:%(levelname)s %(message)s",
          level=(verbose and logging.DEBUG or logging.INFO))
  
      log.info("Checkout/Update org repos")
      repos = ctx.invoke(
          org_checkout,
          organization=organization,
          github_url=github_url,
          github_token=github_token,
          clone_dir=clone_dir,
          verbose=verbose,
          filter=filter,
          exclude=exclude)
  
      log.info('Streaming org changes')
      change_count = 0
      for r in repos:
          change_count += ctx.invoke(
              stream,
              repo_uri=r,
              stream_uri=stream_uri,
              verbose=verbose,
              assume=assume)
      log.info("Streamed %d org changes", change_count)
docs: Stream changes for repos in a GitHub organization.