private Stream createStream ( IProcessingItem sourcePi ) { Stream stream = this . componentFactory . createStream ( sourcePi ) ; this . topology . addStream ( stream ) ; return stream ; }
Creates a platform specific stream .