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.
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.