Method Run

api.go:65–65

Start fetching data and pushing it into the channel. If this call blocks forever, the topology is permanent and acts like a long-running daemon; if this calls exits after it has finished, the topology is meant to be run as a task to process a fixed-size input, and baker will cleanly shutdown after a

(output chan<- *Data)

	// to process a fixed-size input, and baker will cleanly shutdown
	// after all inputs have been fully processed.
	Run(output chan<- *Data) error

	// Force the input to stop as clean as possible, at a good boundary.
	// This is usually issued at the user's request of exiting the process.