Skip to content

Dispatch

openzl.ext.nodes.DispatchString

Bases: Node

Dispatch serial data into one of the dispatched variable outputs according to the tags

Inputs: input: Type.String

Singleton Outputs: tags: Type.Numeric

Variable Outputs: dispatched: Type.String

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
class DispatchString(Node):
    """
    Dispatch serial data into one of the `dispatched` variable outputs according to the `tags`

    Inputs:
    input: Type.String


    Singleton Outputs:
    tags: Type.Numeric


    Variable Outputs:
    dispatched: Type.String
    """

    def __init__(self, *, tags: Sequence[int], num_tags: int) -> None: ...

    def __call__(self, compressor: ext.Compressor, tags: ext.GraphID | ext.graphs.Graph, dispatched: ext.GraphID | ext.graphs.Graph) -> ext.GraphID: ...

    def run(self, edge: ext.Edge) -> list[ext.Edge]: ...

    def run_multi_input(self, edges: Sequence[ext.Edge]) -> list[ext.Edge]: ...

    def build_graph(self, compressor: ext.Compressor, successors: Sequence[ext.GraphID]) -> ext.GraphID: ...

    def parameterize(self, compressor: ext.Compressor) -> ext.NodeID: ...

    @property
    def base_node(self) -> ext.NodeID: ...

base_node property

__call__(compressor, tags, dispatched)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def __call__(self, compressor: ext.Compressor, tags: ext.GraphID | ext.graphs.Graph, dispatched: ext.GraphID | ext.graphs.Graph) -> ext.GraphID: ...

__init__(*, tags, num_tags)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def __init__(self, *, tags: Sequence[int], num_tags: int) -> None: ...

build_graph(compressor, successors)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def build_graph(self, compressor: ext.Compressor, successors: Sequence[ext.GraphID]) -> ext.GraphID: ...

parameterize(compressor)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def parameterize(self, compressor: ext.Compressor) -> ext.NodeID: ...

run(edge)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def run(self, edge: ext.Edge) -> list[ext.Edge]: ...

run_multi_input(edges)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def run_multi_input(self, edges: Sequence[ext.Edge]) -> list[ext.Edge]: ...

openzl.ext.nodes.DispatchSerial

Bases: Node

Dispatch serial data into one of the dispatched variable outputs according to the Instructions.

Inputs: input: Type.Serial

Singleton Outputs: tags: Type.Numeric sizes: Type.Numeric

Variable Outputs: dispatched: Type.Serial

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
class DispatchSerial(Node):
    """
    Dispatch serial data into one of the `dispatched` variable outputs according to the `Instructions`.

    Inputs:
    input: Type.Serial


    Singleton Outputs:
    tags: Type.Numeric
    sizes: Type.Numeric


    Variable Outputs:
    dispatched: Type.Serial
    """

    def __init__(self, *, segment_tags: Sequence[int], segment_sizes: Sequence[int], num_tags: int) -> None: ...

    def __call__(self, compressor: ext.Compressor, tags: ext.GraphID | ext.graphs.Graph, sizes: ext.GraphID | ext.graphs.Graph, dispatched: ext.GraphID | ext.graphs.Graph) -> ext.GraphID: ...

    def run(self, edge: ext.Edge) -> list[ext.Edge]: ...

    def run_multi_input(self, edges: Sequence[ext.Edge]) -> list[ext.Edge]: ...

    def build_graph(self, compressor: ext.Compressor, successors: Sequence[ext.GraphID]) -> ext.GraphID: ...

    def parameterize(self, compressor: ext.Compressor) -> ext.NodeID: ...

    @property
    def base_node(self) -> ext.NodeID: ...

base_node property

__call__(compressor, tags, sizes, dispatched)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def __call__(self, compressor: ext.Compressor, tags: ext.GraphID | ext.graphs.Graph, sizes: ext.GraphID | ext.graphs.Graph, dispatched: ext.GraphID | ext.graphs.Graph) -> ext.GraphID: ...

__init__(*, segment_tags, segment_sizes, num_tags)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def __init__(self, *, segment_tags: Sequence[int], segment_sizes: Sequence[int], num_tags: int) -> None: ...

build_graph(compressor, successors)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def build_graph(self, compressor: ext.Compressor, successors: Sequence[ext.GraphID]) -> ext.GraphID: ...

parameterize(compressor)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def parameterize(self, compressor: ext.Compressor) -> ext.NodeID: ...

run(edge)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def run(self, edge: ext.Edge) -> list[ext.Edge]: ...

run_multi_input(edges)

Source code in build-openzl/py/site-packages/openzl/ext/nodes.pyi
def run_multi_input(self, edges: Sequence[ext.Edge]) -> list[ext.Edge]: ...