temporalio.bridge.worker._Visitor

class documentation

class _Visitor(VisitorFunctions): (source)

Constructor: _Visitor(f, visit_system_nexus_envelope)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Async Method visit_payload Visit a single payload.
Async Method visit_payloads Visit a sequence of payloads together.
Async Method visit_system_nexus_envelope Visit a recognized system Nexus envelope payload.
Instance Variable _f Undocumented
Instance Variable _visit_system_nexus_envelope Undocumented
def __init__(self, f: Callable[[Sequence[Payload]], Awaitable[list[Payload]]], visit_system_nexus_envelope: Callable[[Payload], Awaitable[None]] | None = None): (source)

Undocumented

async def visit_payload(self, payload: 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.

async def visit_system_nexus_envelope(self, payload: Payload): (source)
overrides temporalio.bridge._visitor_functions.VisitorFunctions.visit_system_nexus_envelope

Visit a recognized system Nexus envelope payload.

_f = (source)

Undocumented

_visit_system_nexus_envelope = (source)

Undocumented