Implements the async iterator protocol.
Sends a close signal to the queue.
Retrieves a request from the queue. If the queue is empty, it will wait until a request is available.
OptionalabortSignal: AbortSignalWhen provided, a parked (pending) read is released by rejecting with an abort error once the signal fires. The live send loop passes the connection's abort signal so a waiter is not stranded across reconnect/teardown, where it could otherwise steal a request from the next connection's send loop.
A promise that resolves with the next available request.
Adds a request to the queue. If there is a pending get() call, it
will be resolved with the given request.
The request to send.
Sends an activity end signal to mark the end of user input.
Sends an activity start signal to mark the beginning of user input.
Sends a content object to the queue.
The content to send.
Sends a blob to the model in realtime mode.
The blob to send.
Queue used to send LiveRequest in a live (bidirectional streaming) way.