Used by receiver to get the tokens from the stream queue. Creates a generator that yields tokens from the queue until the END token is received.
Starts a new node and emits the start token.
Emits the end token for the current node.
Close the stream and prevent further tokens from being added. This will send an END token and set the done flag to True.
Used by receiver to get the tokens from the stream queue. Creates a generator that yields tokens from the queue until the END token is received.
Starts a new node and emits the start token.
Emits the end token for the current node.
Close the stream and prevent further tokens from being added. This will send an END token and set the done flag to True.