| 6 | ) |
| 7 | |
| 8 | type eventSourceIterable struct { |
| 9 | sync.RWMutex |
| 10 | observers []chan Item |
| 11 | disposed bool |
| 12 | opts []Option |
| 13 | } |
| 14 | |
| 15 | func newEventSourceIterable(ctx context.Context, next <-chan Item, strategy BackpressureStrategy, opts ...Option) Iterable { |
| 16 | it := &eventSourceIterable{ |
nothing calls this directly
no outgoing calls
no test coverage detected