extract.pipe_iterator
PipeIterator Objects
class PipeIterator(Iterator[PipeItem])
clone_pipes
@staticmethod
def clone_pipes(
pipes: Sequence[Pipe],
existing_cloned_pairs: Dict[int, Pipe] = None
) -> Tuple[List[Pipe], Dict[int, Pipe]]
This will clone pipes and fix the parent/dependent references
ManagedPipeIterator Objects
class ManagedPipeIterator(PipeIterator)
A version of the pipe iterator that gets closed automatically on an exception in next
set_context
def set_context(ctx: List[ContainerInjectableContext]) -> None
Sets list of injectable contexts that will be injected into Container for each call to next