From e61860527e049d53e3b0a03edb89a36702c0aa5b Mon Sep 17 00:00:00 2001 From: "kth050213@naver.com" Date: Thu, 13 Nov 2025 14:39:48 +0900 Subject: [PATCH 1/2] fix(docs): dereference MenuItem pointer in example code --- src/content/docs/docs/flows.mdx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/content/docs/docs/flows.mdx b/src/content/docs/docs/flows.mdx index 0f9f22e9..be465eda 100644 --- a/src/content/docs/docs/flows.mdx +++ b/src/content/docs/docs/flows.mdx @@ -524,7 +524,7 @@ menuSuggestionFlow := genkit.DefineStreamingFlow(g, "menuSuggestionFlow", return Menu{ Theme: input.Theme, - Items: []MenuItem{item}, + Items: []MenuItem{*item}, }, nil }) ``` From cb715df433a58a9449977a270ac59ed5c08738ae Mon Sep 17 00:00:00 2001 From: "kth050213@naver.com" Date: Thu, 13 Nov 2025 16:10:52 +0900 Subject: [PATCH 2/2] fix : streamCh example --- src/content/docs/docs/flows.mdx | 37 ++++++++++++++++++--------------- 1 file changed, 20 insertions(+), 17 deletions(-) diff --git a/src/content/docs/docs/flows.mdx b/src/content/docs/docs/flows.mdx index be465eda..4e2e3e20 100644 --- a/src/content/docs/docs/flows.mdx +++ b/src/content/docs/docs/flows.mdx @@ -621,24 +621,27 @@ Streaming flows can be run like non-streaming flows with `menuSuggestionFlow.Run(ctx, MenuSuggestionInput{Theme: "bistro"})` or they can be streamed: ```go -streamCh, err := menuSuggestionFlow.Stream(context.Background(), MenuSuggestionInput{Theme: "bistro"}) -if err != nil { - log.Fatal(err) -} +streamCh := menuSuggestionFlow.Stream( + context.Background(), + MenuSuggestionInput{Theme: "bistro"}, +) -for result := range streamCh { - if result.Err != nil { - log.Fatalf("Stream error: %v", result.Err) - } - if result.Done { - log.Printf("Menu with %s theme:\n", result.Output.Theme) - for _, item := range result.Output.Items { - log.Printf(" - %s: %s", item.Name, item.Description) - } - } else { - log.Println("Stream chunk:", result.Stream) - } -} +streamCh(func(result *core.StreamingFlowValue[Menu, string], err error) bool { + if err != nil { + log.Fatalf("Stream error: %v", err) + } + + if result.Done { + log.Printf("Menu with %s theme:\n", result.Output.Theme) + for _, item := range result.Output.Items { + log.Printf(" - %s: %s", item.Name, item.Description) + } + } else { + log.Println("Stream chunk:", result.Stream) + } + + return true +}) ```