From 26be55f6f678afeb8ca2a4510d2437e3c3a872db Mon Sep 17 00:00:00 2001 From: Carlos Alexandro Becker Date: Tue, 22 Jul 2025 20:44:41 -0300 Subject: [PATCH] fix: method name --- internal/csync/slices.go | 4 ++-- internal/csync/slices_test.go | 14 +++++++------- internal/llm/agent/agent.go | 4 ++-- 3 files changed, 11 insertions(+), 11 deletions(-) diff --git a/internal/csync/slices.go b/internal/csync/slices.go index 2ce448ef2a1371ecd2e36f955cd1096140cd798a..bc295fc66fa3fcfa8a3e6a7ecf28492b15269200 100644 --- a/internal/csync/slices.go +++ b/internal/csync/slices.go @@ -23,8 +23,8 @@ func NewLazySlice[K any](load func() []K) *LazySlice[K] { return s } -// Iter returns an iterator that yields elements from the slice. -func (s *LazySlice[K]) Iter() iter.Seq[K] { +// Seq returns an iterator that yields elements from the slice. +func (s *LazySlice[K]) Seq() iter.Seq[K] { s.mu.Lock() inner := s.inner s.mu.Unlock() diff --git a/internal/csync/slices_test.go b/internal/csync/slices_test.go index 31f70d73c4b1c975592c17cf41cf0d57b0050b43..731cb96f55dd24cae74f55c0ef8e97ebd28aacaa 100644 --- a/internal/csync/slices_test.go +++ b/internal/csync/slices_test.go @@ -8,7 +8,7 @@ import ( "github.com/stretchr/testify/assert" ) -func TestLazySlice_Iter(t *testing.T) { +func TestLazySlice_Seq(t *testing.T) { t.Parallel() data := []string{"a", "b", "c"} @@ -19,14 +19,14 @@ func TestLazySlice_Iter(t *testing.T) { }) var result []string - for v := range s.Iter() { + for v := range s.Seq() { result = append(result, v) } assert.Equal(t, data, result) } -func TestLazySlice_IterWaitsForLoading(t *testing.T) { +func TestLazySlice_SeqWaitsForLoading(t *testing.T) { t.Parallel() var loaded atomic.Bool @@ -42,11 +42,11 @@ func TestLazySlice_IterWaitsForLoading(t *testing.T) { assert.False(t, loaded.Load(), "should not be loaded immediately") var result []string - for v := range s.Iter() { + for v := range s.Seq() { result = append(result, v) } - assert.True(t, loaded.Load(), "should be loaded after Iter") + assert.True(t, loaded.Load(), "should be loaded after Seq") assert.Equal(t, data, result) } @@ -58,7 +58,7 @@ func TestLazySlice_EmptySlice(t *testing.T) { }) var result []string - for v := range s.Iter() { + for v := range s.Seq() { result = append(result, v) } @@ -76,7 +76,7 @@ func TestLazySlice_EarlyBreak(t *testing.T) { }) var result []string - for v := range s.Iter() { + for v := range s.Seq() { result = append(result, v) if len(result) == 2 { break diff --git a/internal/llm/agent/agent.go b/internal/llm/agent/agent.go index 02961969f8d16ed316f91132c944be1ea2311f48..72697cb0ac801f013a094dc5c44a3152f1443af1 100644 --- a/internal/llm/agent/agent.go +++ b/internal/llm/agent/agent.go @@ -445,7 +445,7 @@ func (a *agent) createUserMessage(ctx context.Context, sessionID, content string func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msgHistory []message.Message) (message.Message, *message.Message, error) { ctx = context.WithValue(ctx, tools.SessionIDContextKey, sessionID) - eventChan := a.provider.StreamResponse(ctx, msgHistory, slices.Collect(a.tools.Iter())) + eventChan := a.provider.StreamResponse(ctx, msgHistory, slices.Collect(a.tools.Seq())) assistantMsg, err := a.messages.Create(ctx, sessionID, message.CreateMessageParams{ Role: message.Assistant, @@ -494,7 +494,7 @@ func (a *agent) streamAndHandleEvents(ctx context.Context, sessionID string, msg default: // Continue processing var tool tools.BaseTool - for availableTool := range a.tools.Iter() { + for availableTool := range a.tools.Seq() { if availableTool.Info().Name == toolCall.Name { tool = availableTool break