waitmap

package

v0.7.5 Latest Latest Go to latest Published: Jun 30, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type WaitMap[K comparable, V any] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

WaitMap is a key-value store that enables not only setting and getting values from a map, but also waiting until value for a key becomes available.

func New[K comparable, V any](size int) *WaitMap[K, V]

New creates a new WaitMap.

func (w *WaitMap[K, V]) Get(key K) (V, bool)

Get will return the current value for the key, if any.

func (w *WaitMap[K, V]) Set(key K, value V)

Set sets the value for a key. If the value already exists, we append it to a list.

func (w *WaitMap[K, V]) Wait(key K) V

Wait will wait until the value for a key becomes available.

func (w *WaitMap[K, V]) WaitFor(ctx context.Context, key K) (V, bool)

WaitFor will wait for the value for a key to become available, but no longer than the specified duration.