mesos::internal::recordio Namespace Reference

Namespaces
	internal

Classes
class	Reader
	Provides RecordIO decoding on top of an http::Pipe::Reader. More...

Functions
template<typename T >
process::Future< Nothing >	transform (process::Owned< Reader< T >> &&reader, const std::function< std::string(const T &)> &func, process::http::Pipe::Writer writer)
	This is a helper function that reads records from a Reader, applies a transformation to the records and writes to the pipe. More...

Function Documentation

template<typename T >

process::Future<Nothing> mesos::internal::recordio::transform	(	process::Owned< Reader< T >> &&	reader,
		const std::function< std::string(const T &)> &	func,
		process::http::Pipe::Writer	writer
	)

This is a helper function that reads records from a Reader, applies a transformation to the records and writes to the pipe.

Returns a failed future if there are any errors reading or writing. The future is satisfied when we get a EOF.

TODO(vinod): Split this method into primitives that can transform a stream of bytes to a stream of typed records that can be further transformed. See the TODO above in Reader for further details.