Ask a question to get started
Enter to send•Shift+Enter new line
A configurable PubSub Topic.
Topic( self, typ: type[Value], accumulate: bool = False, )
Generic[Value]
BaseChannel[Sequence[Value], Value | list[Value], list[Value]]
typ
type[Value]
The type of the value stored in the channel.
accumulate
bool
False
Whether to accumulate values across steps. If False, the channel will be emptied after each step.
The type of the update received by the channel.
Return a copy of the channel.
Notify the channel that a subscribed task ran.
Notify the channel that the Pregel run is finishing.
