code: def update_pipe_module():
      
      module_dir = __all__
      operators = stream.__dict__
      for key, value in operators.items():
          if getattr(value, 'pipe', None):
              globals()[key] = value.pipe
              if key not in module_dir:
                  module_dir.append(key)
docs: Populate the pipe module dynamically.