git.iko.soy/crush
on main help sign in
fix: method name
26be55fCarlos Alexandro Becker
internal/csync/slices.go+2−2
compare with main
unifiedsplit
@@ -23,8 +23,8 @@ func NewLazySlice[K any](load func() []K) *LazySlice[K] {
23 return s
23 return s
24}
24}
25
25
26−// Iter returns an iterator that yields elements from the slice.
26+// Seq returns an iterator that yields elements from the slice.
27−func (s *LazySlice[K]) Iter() iter.Seq[K] {
27+func (s *LazySlice[K]) Seq() iter.Seq[K] {
28 s.mu.Lock()
28 s.mu.Lock()
29 inner := s.inner
29 inner := s.inner
30 s.mu.Unlock()
30 s.mu.Unlock()
internal/csync/slices_test.go+7−7
@@ -8,7 +8,7 @@ import (
8 "github.com/stretchr/testify/assert"
8 "github.com/stretchr/testify/assert"
9)
9)
10
10
11−func TestLazySlice_Iter(t *testing.T) {
11+func TestLazySlice_Seq(t *testing.T) {
12 t.Parallel()
12 t.Parallel()
13
13
14 data := []string{"a", "b", "c"}
14 data := []string{"a", "b", "c"}
@@ -19,14 +19,14 @@ func TestLazySlice_Iter(t *testing.T) {
19 })
19 })
20
20
21 var result []string
21 var result []string
22− for v := range s.Iter() {
22+ for v := range s.Seq() {
23 result = append(result, v)
23 result = append(result, v)
24 }
24 }
25
25
26 assert.Equal(t, data, result)
26 assert.Equal(t, data, result)
27}
27}
28
28
29−func TestLazySlice_IterWaitsForLoading(t *testing.T) {
29+func TestLazySlice_SeqWaitsForLoading(t *testing.T) {
30 t.Parallel()
30 t.Parallel()
31
31
32 var loaded atomic.Bool
32 var loaded atomic.Bool
@@ -42,11 +42,11 @@ func TestLazySlice_IterWaitsForLoading(t *testing.T) {
42 assert.False(t, loaded.Load(), "should not be loaded immediately")
42 assert.False(t, loaded.Load(), "should not be loaded immediately")
43
43
44 var result []string
44 var result []string
45− for v := range s.Iter() {
45+ for v := range s.Seq() {
46 result = append(result, v)
46 result = append(result, v)
47 }
47 }
48
48
49− assert.True(t, loaded.Load(), "should be loaded after Iter")
49+ assert.True(t, loaded.Load(), "should be loaded after Seq")
50 assert.Equal(t, data, result)
50 assert.Equal(t, data, result)
51}
51}
52
52
@@ -58,7 +58,7 @@ func TestLazySlice_EmptySlice(t *testing.T) {
58 })
58 })
59
59
60 var result []string
60 var result []string
61− for v := range s.Iter() {
61+ for v := range s.Seq() {
62 result = append(result, v)
62 result = append(result, v)
63 }
63 }
64
64
@@ -76,7 +76,7 @@ func TestLazySlice_EarlyBreak(t *testing.T) {
76 })
76 })
77
77
78 var result []string
78 var result []string
79− for v := range s.Iter() {
79+ for v := range s.Seq() {
80 result = append(result, v)
80 result = append(result, v)
81 if len(result) == 2 {
81 if len(result) == 2 {
82 break
82 break
internal/llm/agent/agent.go+2−2
@@ -445,7 +445,7 @@ func (a *agent) createUserMessage(ctx context.Context, sessionID, content string
445
445
446func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msgHistory []message.Message) (message.Message, *message.Message, error) {
446func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msgHistory []message.Message) (message.Message, *message.Message, error) {
447 ctx = context.WithValue(ctx, tools.SessionIDContextKey, sessionID)
447 ctx = context.WithValue(ctx, tools.SessionIDContextKey, sessionID)
448− eventChan := a.provider.StreamResponse(ctx, msgHistory, slices.Collect(a.tools.Iter()))
448+ eventChan := a.provider.StreamResponse(ctx, msgHistory, slices.Collect(a.tools.Seq()))
449
449
450 assistantMsg, err := a.messages.Create(ctx, sessionID, message.CreateMessageParams{
450 assistantMsg, err := a.messages.Create(ctx, sessionID, message.CreateMessageParams{
451 Role: message.Assistant,
451 Role: message.Assistant,
@@ -494,7 +494,7 @@ func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msg
494 default:
494 default:
495 // Continue processing
495 // Continue processing
496 var tool tools.BaseTool
496 var tool tools.BaseTool
497− for availableTool := range a.tools.Iter() {
497+ for availableTool := range a.tools.Seq() {
498 if availableTool.Info().Name == toolCall.Name {
498 if availableTool.Info().Name == toolCall.Name {
499 tool = availableTool
499 tool = availableTool
500 break
500 break