utils

package

v0.8.0 Latest Latest Go to latest Published: Apr 12, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func Map[T, V any](ts []T, fn func(T) V) []V

func Reduce[T, V any](ts []T, fn func(V, T) V, initial V) V

type Emitter[T Event[V], V any] interface {
	Emit(event T)
	Subscribe(eventName goiamuniverse.Event, subscriber Subscriber[T, V])
}

func NewEmitter[T Event[V], V any]() Emitter[T, V]

NewEmitter creates a new Emitter instance for the specified event type.

type Event[T any] interface {
	Name() goiamuniverse.Event
	Payload() T
	Metadata() sdk.Metadata
	Context() context.Context
}

type Subscriber[T Event[V], V any] interface {
	HandleEvent(event T)
}