Function newFactoryIterable

iterable_factory.go:7–9

(factory func(opts ...Option) <-chan Item)

}

func newFactoryIterable(factory func(opts ...Option) <-chan Item) Iterable {
	return &factoryIterable{factory: factory}
}

func (i *factoryIterable) Observe(opts ...Option) <-chan Item {
	return i.factory(opts...)