Method IterBuffered

zutils/shard_lock_map.go:371–380

IterBuffered returns a buffered iterator which could be used in a for range loop.

()

// IterBuffered returns a buffered iterator which could be used in a for range loop.
func (slm ShardLockMaps) IterBuffered() <-chan Tuple {
	chanList := snapshot(slm)
	total := 0
	for _, c := range chanList {
		total += cap(c)
	}
	ch := make(chan Tuple, total)
	go fanIn(chanList, ch)
	return ch
}

// Items returns all items as map[string]interface{}
func (slm ShardLockMaps) Items() map[string]interface{} {