temporalio.worker._nexus._PayloadTransformVisitor

class documentation

class _PayloadTransformVisitor(VisitorFunctions): (source)

Adapts a payload-sequence transform for use with PayloadVisitor.

Method	`__init__`	Undocumented
Async Method	`visit_payload`	Visit a single payload.
Async Method	`visit_payloads`	Visit a sequence of payloads together.
Instance Variable	`_f`	Undocumented

Inherited from VisitorFunctions:

Method	`checkpoint`	Return a marker for visits scheduled after this point, if supported.
Async Method	`drain_since`	Wait for visits scheduled after `checkpoint` to finish.
Async Method	`visit_system_nexus_envelope`	Visit a recognized system Nexus envelope payload.

def __init__(self, f: Callable[[Sequence[temporalio.api.common.v1.Payload]], Awaitable[list[temporalio.api.common.v1.Payload]]]): (source) ¶

Undocumented

async def visit_payload(self, payload: temporalio.api.common.v1.Payload): (source) ¶

overrides temporalio.bridge._visitor_functions.VisitorFunctions.visit_payload

Visit a single payload.

async def visit_payloads(self, payloads: PayloadSequence): (source) ¶

overrides temporalio.bridge._visitor_functions.VisitorFunctions.visit_payloads

Visit a sequence of payloads together.

Undocumented