createSource: Returns a source that can be used to continually read data
createSink:Returns a sink that can be used to continually write data.