Function NewMemoryQueueFactory

fs/contube/memory.go:37–42

(ctx context.Context)

}

func NewMemoryQueueFactory(ctx context.Context) TubeFactory {
	return &MemoryQueueFactory{
		ctx:    ctx,
		queues: make(map[string]*queue),
	}
}

func (f *MemoryQueueFactory) getOrCreateChan(name string) chan Record {
	f.mu.Lock()