From 8c167e042aafaf3afec861e41a57d462b8fdf694 Mon Sep 17 00:00:00 2001 From: Kujtim Hoxha Date: Mon, 19 Jan 2026 11:46:53 +0100 Subject: [PATCH] chore: remove unused func --- internal/agent/tools/mcp/init.go | 1 - internal/pubsub/broker.go | 20 -------------------- 2 files changed, 21 deletions(-) diff --git a/internal/agent/tools/mcp/init.go b/internal/agent/tools/mcp/init.go index 32d337156650a2b3a1b122be181429b89df63b29..69b10f711c2d1fd247f95ed779be5d7a38ea3a7f 100644 --- a/internal/agent/tools/mcp/init.go +++ b/internal/agent/tools/mcp/init.go @@ -129,7 +129,6 @@ func Close() error { case <-done: case <-time.After(5 * time.Second): } - broker.Shutdown() return nil } diff --git a/internal/pubsub/broker.go b/internal/pubsub/broker.go index 6986b1b7bb234e004a97cc8db7f381d422ebada6..4e5195ce5b1ef166ed211542f8387655910bf9f4 100644 --- a/internal/pubsub/broker.go +++ b/internal/pubsub/broker.go @@ -18,16 +18,6 @@ func NewBroker[T any]() *Broker[T] { } } -// NewBrokerWithOptions creates a new broker (options ignored for compatibility). -func NewBrokerWithOptions[T any](_, _ int) *Broker[T] { - return NewBroker[T]() -} - -// Shutdown removes all listeners. -func (b *Broker[T]) Shutdown() { - b.signal.Reset() -} - // AddListener registers a callback for events. func (b *Broker[T]) AddListener(key string, fn func(Event[T])) { b.signal.AddListener(func(_ context.Context, event Event[T]) { @@ -35,18 +25,8 @@ func (b *Broker[T]) AddListener(key string, fn func(Event[T])) { }, key) } -// RemoveListener removes a listener by key. -func (b *Broker[T]) RemoveListener(key string) { - b.signal.RemoveListener(key) -} - // Publish emits an event to all listeners without blocking. func (b *Broker[T]) Publish(ctx context.Context, t EventType, payload T) { event := Event[T]{Type: t, Payload: payload} go b.signal.Emit(ctx, event) } - -// Len returns the number of listeners. -func (b *Broker[T]) Len() int { - return b.signal.Len() -}