git.iko.soy/crush
on main help sign in
fix: method name
commit26be55f6f678afeb8ca2a4510d2437e3c3a872db authorCarlos Alexandro Becker <caarlos0@users.noreply.github.com> dateTue 22 Jul 2025, 20:44 (1 year ago) parentaf1514b
3 files changed+11−11
compare with main
unifiedsplit
internal/csync/slices.go+2−2 internal/csync/slices_test.go+7−7 internal/llm/agent/agent.go+2−2
internal/csync/slices.go+2−2
@@ -23,8 +23,8 @@ func NewLazySlice[K any](load func() []K) *LazySlice[K] {
2323 return s
2424}
2525
26−// Iter returns an iterator that yields elements from the slice.
27−func (s *LazySlice[K]) Iter() iter.Seq[K] {
26+// Seq returns an iterator that yields elements from the slice.
27+func (s *LazySlice[K]) Seq() iter.Seq[K] {
2828 s.mu.Lock()
2929 inner := s.inner
3030 s.mu.Unlock()
internal/csync/slices_test.go+7−7
@@ -8,7 +8,7 @@ import (
88 "github.com/stretchr/testify/assert"
99)
1010
11−func TestLazySlice_Iter(t *testing.T) {
11+func TestLazySlice_Seq(t *testing.T) {
1212 t.Parallel()
1313
1414 data := []string{"a", "b", "c"}
@@ -19,14 +19,14 @@ func TestLazySlice_Iter(t *testing.T) {
1919 })
2020
2121 var result []string
22− for v := range s.Iter() {
22+ for v := range s.Seq() {
2323 result = append(result, v)
2424 }
2525
2626 assert.Equal(t, data, result)
2727}
2828
29−func TestLazySlice_IterWaitsForLoading(t *testing.T) {
29+func TestLazySlice_SeqWaitsForLoading(t *testing.T) {
3030 t.Parallel()
3131
3232 var loaded atomic.Bool
@@ -42,11 +42,11 @@ func TestLazySlice_IterWaitsForLoading(t *testing.T) {
4242 assert.False(t, loaded.Load(), "should not be loaded immediately")
4343
4444 var result []string
45− for v := range s.Iter() {
45+ for v := range s.Seq() {
4646 result = append(result, v)
4747 }
4848
49− assert.True(t, loaded.Load(), "should be loaded after Iter")
49+ assert.True(t, loaded.Load(), "should be loaded after Seq")
5050 assert.Equal(t, data, result)
5151}
5252
@@ -58,7 +58,7 @@ func TestLazySlice_EmptySlice(t *testing.T) {
5858 })
5959
6060 var result []string
61− for v := range s.Iter() {
61+ for v := range s.Seq() {
6262 result = append(result, v)
6363 }
6464
@@ -76,7 +76,7 @@ func TestLazySlice_EarlyBreak(t *testing.T) {
7676 })
7777
7878 var result []string
79− for v := range s.Iter() {
79+ for v := range s.Seq() {
8080 result = append(result, v)
8181 if len(result) == 2 {
8282 break
internal/llm/agent/agent.go+2−2
@@ -445,7 +445,7 @@ func (a *agent) createUserMessage(ctx context.Context, sessionID, content string
445445
446446func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msgHistory []message.Message) (message.Message, *message.Message, error) {
447447 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()))
449449
450450 assistantMsg, err := a.messages.Create(ctx, sessionID, message.CreateMessageParams{
451451 Role: message.Assistant,
@@ -494,7 +494,7 @@ func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msg
494494 default:
495495 // Continue processing
496496 var tool tools.BaseTool
497− for availableTool := range a.tools.Iter() {
497+ for availableTool := range a.tools.Seq() {
498498 if availableTool.Info().Name == toolCall.Name {
499499 tool = availableTool
500500 break