MCPcopy Create free account
hub / github.com/ReactiveX/RxGo / newSliceIterable

Function newSliceIterable

iterable_slice.go:8–13  ·  view source on GitHub ↗
(items []Item, opts ...Option)

Source from the content-addressed store, hash-verified

6}
7
8func newSliceIterable(items []Item, opts ...Option) Iterable {
9 return &sliceIterable{
10 items: items,
11 opts: opts,
12 }
13}
14
15func (i *sliceIterable) Observe(opts ...Option) <-chan Item {
16 option := parseOptions(append(i.opts, opts...)...)

Calls

no outgoing calls

Used in the wild real call sites across dependent graphs

searching dependent graphs…