code: private Stream createStream(IProcessingItem sourcePi) {
          Stream stream = this.componentFactory.createStream(sourcePi);
          this.topology.addStream(stream);
          return stream;
      }
docs: Creates a platform specific stream.
  
  @param sourcePi
  source processing item.
  @return