Hi here there an example for persistance
Hi here there an example for persistance text streaming which has the has the thread and messages schema. Iam finding an issue where i need to pass my threadId to use with useStream() from "@convex-dev/persistent-text-streaming/react".
My goal is to list all message base on my threadId,
Is there a way for me to pass a body?
My goal is to list all message base on my threadId,
Is there a way for me to pass a body?
/**
* React hook for persistent text streaming.
*
* @param getPersistentBody - A query function reference that returns the body
* of a stream using the component's `getStreamBody` method.
* @param streamUrl - The URL of the http action that will kick off the stream
* generation and stream the result back to the client using the component's
* `stream` method.
* @param driven - Whether this particular session is driving the stream. Set this
* to true if this is the client session that first created the stream using the
* component's `createStream` method. If you're simply reloading an existing
* stream, set this to false.
* @param streamId - The ID of the stream. If this is not provided, the return
* value will be an empty string for the stream body and the status will be
* `pending`.
* @returns The body and status of the stream.
*/
export function useStream(
getPersistentBody: FunctionReference<
"query",
"public",
{ streamId: string },
StreamBody
>,
streamUrl: URL,
driven: boolean,
streamId: StreamId | undefined,
opts?: {
// If provided, this will be passed as the Authorization header.
authToken?: string | null;
// If provided, these will be passed as additional headers.
headers?: Record<string, string>;
}
) {/**
* React hook for persistent text streaming.
*
* @param getPersistentBody - A query function reference that returns the body
* of a stream using the component's `getStreamBody` method.
* @param streamUrl - The URL of the http action that will kick off the stream
* generation and stream the result back to the client using the component's
* `stream` method.
* @param driven - Whether this particular session is driving the stream. Set this
* to true if this is the client session that first created the stream using the
* component's `createStream` method. If you're simply reloading an existing
* stream, set this to false.
* @param streamId - The ID of the stream. If this is not provided, the return
* value will be an empty string for the stream body and the status will be
* `pending`.
* @returns The body and status of the stream.
*/
export function useStream(
getPersistentBody: FunctionReference<
"query",
"public",
{ streamId: string },
StreamBody
>,
streamUrl: URL,
driven: boolean,
streamId: StreamId | undefined,
opts?: {
// If provided, this will be passed as the Authorization header.
authToken?: string | null;
// If provided, these will be passed as additional headers.
headers?: Record<string, string>;
}
) {
