Method end

observable.go:126–126 · view source on GitHub ↗

(ctx context.Context, dst chan<- Item)

Source from the content-addressed store, hash-verified

124	next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions)
125	err(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions)
126	end(ctx context.Context, dst chan<- Item)
127	gatherNext(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions)
128	}
129

runSequentialFunction · 0.65

runParallelFunction · 0.65

runFirstItemFunction · 0.65

mapOperatorOptionalSingleoptionalsingle.go

allOperatorobservable_operator.go

averageFloat32Operatorobservable_operator.go

averageFloat64Operatorobservable_operator.go

averageIntOperatorobservable_operator.go

averageInt8Operatorobservable_operator.go

averageInt16Operatorobservable_operator.go

averageInt32Operatorobservable_operator.go

averageInt64Operatorobservable_operator.go

bufferWithCountOperatorobservable_operator.go

containsOperatorobservable_operator.go

countOperatorobservable_operator.go

no outgoing calls

no test coverage detected