Struct ObservableImpl

observable.go:94–97

ObservableImpl implements Observable.

// ObservableImpl implements Observable.
type ObservableImpl struct {
	parent   context.Context
	iterable Iterable
}

func defaultErrorFuncOperator(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
	item.SendContext(ctx, dst)