Imports github.com/RuiFG/streaming/streaming-core/element github.com/RuiFG/streaming/streaming-core/operator github.com/RuiFG/streaming/streaming-core/stream github.com/pkg/errors Standard library imports fmt io/fs os path time