Function newCreateIterable

iterable_create.go:16–32

(fs []Producer, opts ...Option)

}

func newCreateIterable(fs []Producer, opts ...Option) Iterable {
	option := parseOptions(opts...)
	next := option.buildChannel()
	ctx := option.buildContext(emptyContext)

	go func() {
		defer close(next)
		for _, f := range fs {
			f(ctx, next)
		}
	}()

	return &createIterable{
		opts: opts,
		next: next,
	}
}

func (i *createIterable) Observe(opts ...Option) <-chan Item {
	mergedOptions := append(i.opts, opts...)