[streaming] StreamSourceCollector wip