PartQueue<T>
Namespace: Vercel.AI.Operations
public sealed class PartQueue<T>Async queue used to hand stream parts to one consumer.
Type parameters
| Name | Description |
|---|---|
T |
Inheritance: object
Methods
Section titled “Methods”Complete(Exception?)
Section titled “Complete(Exception?)”public void Complete(Exception? error)Completes the queue, optionally with an error.
Parameters
| Name | Type | Description |
|---|---|---|
error |
Exception |
Dequeue()
Section titled “Dequeue()”public T Dequeue()Removes the next part. Call after CancellationToken) returns true.
Returns: T
Enqueue(T)
Section titled “Enqueue(T)”public void Enqueue(T item)Adds a part.
Parameters
| Name | Type | Description |
|---|---|---|
item |
T |
WaitAsync(CancellationToken)
Section titled “WaitAsync(CancellationToken)”public Task<bool> WaitAsync(CancellationToken cancellationToken)Reads the next part. Returns false when the queue is complete.
Parameters
| Name | Type | Description |
|---|---|---|
cancellationToken |
CancellationToken |
Returns: Task<bool>
Apache-2.0 · Copyright 2023 Vercel, Inc. · unofficial community port, not an official Vercel product