ޠj;SSKJr SSKJrJr SSKJr SSKJrJ r J r SSK J r SSK Jr SSKJr \ "S5r\ "S 5r\ "S 5rS r"S S \ \\\4\5rg)) annotations)ABCabstractmethod)Sequence)AnyGenericTypeVar)Self)MISSING)EmptyChannelErrorValueUpdate Checkpoint) BaseChannelc\rSrSrSrSrSSSjjr\\SSj55r \\SSj55r SSjr SSjr \SS j5r \SS j5rSS jr\SS j5rSS jrSSjrSrg)rzBase class for all channels.)keytypcXlX lg)N)rr)selfrrs Q/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph/channels/base.py__init__BaseChannel.__init__s cg)z,The type of the value stored in the channel.Nrs r ValueTypeBaseChannel.ValueTypercg)z/The type of the update received by the channel.Nrrs r UpdateTypeBaseChannel.UpdateType!r rc@URUR55$)zReturn a copy of the channel. By default, delegates to `checkpoint()` and `from_checkpoint()`. Subclasses can override this method with a more efficient implementation. )from_checkpoint checkpointrs rcopyBaseChannel.copy(s##DOO$566rcPUR5$![a [s$f=f)zReturn a serializable representation of the channel's current state. Raises `EmptyChannelError` if the channel is empty (never updated yet), or doesn't support checkpoints. )getr r rs rr&BaseChannel.checkpoint1s'  88:   N s %%cg)zReturn a new identical channel, optionally initialized from a checkpoint. If the checkpoint contains complex data structures, they should be copied. Nr)rr&s rr%BaseChannel.from_checkpoint<r rcg)zqReturn the current value of the channel. Raises `EmptyChannelError` if the channel is empty (never updated yet).Nrrs rr*BaseChannel.getEr rcFUR5 g![a gf=f)zReturn `True` if the channel is available (not empty), `False` otherwise. Subclasses should override this method to provide a more efficient implementation than calling `get()` and catching `EmptyChannelError`. TF)r*r rs r is_availableBaseChannel.is_availableKs%   HHJ   s   cg)aUpdate the channel's value with the given sequence of updates. The order of the updates in the sequence is arbitrary. This method is called by Pregel for all channels at the end of each step. If there are no updates, it is called with an empty sequence. Raises `InvalidUpdateError` if the sequence of updates is invalid. Returns `True` if the channel was updated, `False` otherwise.Nr)rvaluess rupdateBaseChannel.updateYr rcg)zNotify the channel that a subscribed task ran. By default, no-op. A channel can use this method to modify its state, preventing the value from being consumed again. Returns `True` if the channel was updated, `False` otherwise. Frrs rconsumeBaseChannel.consumeercg)zNotify the channel that the Pregel run is finishing. By default, no-op. A channel can use this method to modify its state, preventing finish. Returns `True` if the channel was updated, `False` otherwise. Frrs rfinishBaseChannel.finishpr:rN))rrrstrreturnNone)r@r)r@r )r@Checkpoint | Any)r&rBr@r )r@r )r@bool)r4zSequence[Update]r@rC)__name__ __module__ __qualname____firstlineno____doc__ __slots__rpropertyrrr"r'r&r%r*r1r5r8r<__static_attributes__rrrrrs&I;;>> 7   SS  I I  rrN) __future__rabcrrcollections.abcrtypingrrr typing_extensionsr langgraph._internal._typingr langgraph.errorsr r rr__all__rrrrrTs\"#$(("/.   \ " f'%34cfr