Stream tagging implementation