extract.pipe_iterator

PipeIterator Objects

class PipeIterator(Iterator[PipeItem])

[view_source]

clone_pipes

@staticmethod
def clone_pipes(
    pipes: Sequence[Pipe],
    existing_cloned_pairs: Dict[int, Pipe] = None
) -> Tuple[List[Pipe], Dict[int, Pipe]]

[view_source]

This will clone pipes and fix the parent/dependent references

ManagedPipeIterator Objects

class ManagedPipeIterator(PipeIterator)

[view_source]

A version of the pipe iterator that gets closed automatically on an exception in next

set_context

def set_context(ctx: List[ContainerInjectableContext]) -> None

[view_source]

Sets list of injectable contexts that will be injected into Container for each call to next