C# FileHelperAsyncEngine类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了C#中FileHelperAsyncEngine类的典型用法代码示例。如果您正苦于以下问题：C# FileHelperAsyncEngine类的具体用法？C# FileHelperAsyncEngine怎么用？C# FileHelperAsyncEngine使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

FileHelperAsyncEngine类属于命名空间，在下文中一共展示了FileHelperAsyncEngine类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C#代码示例。

示例1: RunAsyncConstructor

        private static void RunAsyncConstructor(Encoding enc, params string[] pathElements)
        {
            var asyncEngine = new FileHelperAsyncEngine<CustomersVerticalBar>(enc);
            Assert.AreEqual(enc, asyncEngine.Encoding);

            CoreRunAsync(asyncEngine, pathElements);
        }

开发者ID:mgmccarthy，项目名称:FileHelpers，代码行数:7，代码来源:Encoding.cs

示例2: AsyncRead

		public void AsyncRead()
		{

            FileHelperAsyncEngine<SampleType> asyncEngine = new FileHelperAsyncEngine<SampleType>();

			SampleType rec1, rec2;
            asyncEngine.BeginReadFile(Common.TestPath(@"Good\test1.txt"));

			rec1 = asyncEngine.ReadNext();
			Assert.IsNotNull(rec1);
			rec2 = asyncEngine.ReadNext();
			Assert.IsNotNull(rec1);

			Assert.IsTrue(rec1 != rec2);

			rec1 = asyncEngine.ReadNext();
			Assert.IsNotNull(rec2);
			rec1 = asyncEngine.ReadNext();
			Assert.IsNotNull(rec2);

			Assert.IsTrue(rec1 != rec2);

			Assert.AreEqual(0, asyncEngine.ErrorManager.ErrorCount);

            asyncEngine.Close();

		}

开发者ID:BD-GitHub，项目名称:filehelpers，代码行数:27，代码来源:ReadersGeneric.cs

示例3: AsyncFieldIndexBad2

        public void AsyncFieldIndexBad2()
        {
            var engine = new FileHelperAsyncEngine(typeof (SampleType));

            Assert.Throws<BadUsageException>(()
                => engine.WriteNextValues());
        }

开发者ID:abombss，项目名称:FileHelpers，代码行数:7，代码来源:WritersFieldIndexers.cs

示例4: RunAsyncConstructor

        private void RunAsyncConstructor(Encoding enc, params string[] pathElements)
        {
            asyncEngine = new FileHelperAsyncEngine<CustomersVerticalBar>(enc);
            Check.That(enc).IsEqualTo(asyncEngine.Encoding);

            CoreRunAsync(pathElements);
        }

开发者ID:mgmccarthy，项目名称:FileHelpers，代码行数:7，代码来源:FileEncoding.cs

示例5: RunAsyncConstructor

		private void RunAsyncConstructor(string fileName, Encoding enc)
		{
			asyncEngine = new FileHelperAsyncEngine(typeof (CustomersVerticalBar), enc);
			Assert.AreEqual(enc, asyncEngine.Encoding);

			CoreRunAsync(fileName);
		}

开发者ID:BD-GitHub，项目名称:filehelpers，代码行数:7，代码来源:Encoding.cs

示例6: AsyncFieldIndex1

        public void AsyncFieldIndex1()
        {
            var engine = new FileHelperAsyncEngine(typeof (SampleType));

            var sw = new StringWriter();
            engine.BeginWriteStream(sw);

            engine[0] = new DateTime(2003, 2, 1);
            engine[1] = "B";
            engine[2] = 18;

            engine.WriteNextValues();

            engine.Close();

            engine.BeginReadString(sw.GetStringBuilder().ToString());
            engine.ReadNext();

            Assert.AreEqual(new DateTime(2003, 2, 1), engine[0]);
            Assert.AreEqual("B", engine[1]);
            Assert.AreEqual(18, engine[2]);

            Assert.AreEqual(new DateTime(2003, 2, 1), engine.LastRecordValues[0]);
            Assert.AreEqual("B", engine.LastRecordValues[1]);
            Assert.AreEqual(18, engine.LastRecordValues[2]);

            engine.ReadNext();

            Assert.IsNull(engine.LastRecord);
            Assert.IsNull(engine.LastRecordValues);
        }

开发者ID:abombss，项目名称:FileHelpers，代码行数:31，代码来源:WritersFieldIndexers.cs

示例7: Import

        internal void Import()
        {
            var repo = new AddressRepository();
            using (var engine = new FileHelperAsyncEngine<REDPostalAddressImport>())
            {
                engine.BeginReadFile(_fileName);

                var swWrite = Stopwatch.StartNew();
                var processed = 0L;

                var postalAddresses = new List<PostalAddress>();
                foreach (REDPostalAddressImport postalAddress in engine)
                {
                    postalAddresses.Add(Convert(postalAddress));
                    if (postalAddresses.Count == 100000)
                    {
                        processed += postalAddresses.Count;

                        repo.Write(postalAddresses);
                        postalAddresses.Clear();

                        Console.WriteLine("Processed {0} in {1}", processed, swWrite.Elapsed);
                        swWrite.Restart();
                    }
                }
                if (postalAddresses.Count > 0)
                {
                    repo.Write(postalAddresses);
                    processed += postalAddresses.Count;
                    Console.WriteLine("Processed {0} in {1}", processed, swWrite.Elapsed);
                }
            }
        }

开发者ID:kiwipiet，项目名称:AddressFinder，代码行数:33，代码来源:REDAddressImporter.cs

示例8: WriteNullAsync

		public void WriteNullAsync()
		{
			asyncEngine = new FileHelperAsyncEngine(typeof (SampleType));

			asyncEngine.BeginWriteFile("tempNull.txt");

			asyncEngine.WriteNext(new SampleType());
			asyncEngine.WriteNext(new SampleType());
			asyncEngine.WriteNext(new SampleType());

			asyncEngine.Close();

			asyncEngine.BeginReadFile("tempNull.txt");
			SampleType[] res = (SampleType[]) asyncEngine.ReadNexts(5000);
			asyncEngine.Close();

			Assert.AreEqual(3, res.Length);
			Assert.AreEqual(3, asyncEngine.TotalRecords);
			Assert.AreEqual(0, asyncEngine.ErrorManager.ErrorCount);

			Assert.AreEqual(DateTime.MinValue, res[0].Field1);
			Assert.AreEqual("", res[0].Field2);
			Assert.AreEqual(0, res[0].Field3);

			if (File.Exists("tempNull.txt")) File.Delete("tempNull.txt");
		}

开发者ID:BD-GitHub，项目名称:filehelpers，代码行数:26，代码来源:NullValues.cs

示例9: AsyncRead

		public void AsyncRead()
		{
			asyncEngine = new FileHelperAsyncEngine(typeof (SampleType));

			SampleType rec1, rec2;

			Common.BeginReadTest(asyncEngine, @"Good\test1.txt");

			rec1 = (SampleType) asyncEngine.ReadNext();
			Assert.IsNotNull(rec1);
			rec2 = (SampleType) asyncEngine.ReadNext();
			Assert.IsNotNull(rec1);

			Assert.IsTrue(rec1 != rec2);

			rec1 = (SampleType) asyncEngine.ReadNext();
			Assert.IsNotNull(rec2);
			rec1 = (SampleType) asyncEngine.ReadNext();
			Assert.IsNotNull(rec2);

			Assert.IsTrue(rec1 != rec2);

			Assert.AreEqual(0, asyncEngine.ErrorManager.ErrorCount);

			asyncEngine.Close();
		}

开发者ID:BD-GitHub，项目名称:filehelpers，代码行数:26，代码来源:Readers.cs

示例10: AsyncRead

        public void AsyncRead()
        {
            asyncEngine = new FileHelperAsyncEngine(typeof (SampleType));

            SampleType rec1, rec2;

            Assert.AreEqual(0, asyncEngine.LineNumber);
            TestCommon.BeginReadTest(asyncEngine, "Good", "Test1.txt");

            rec1 = (SampleType) asyncEngine.ReadNext();
            Assert.IsNotNull(rec1);
            Assert.AreEqual(1, asyncEngine.LineNumber);

            rec2 = (SampleType) asyncEngine.ReadNext();
            Assert.IsNotNull(rec1);
            Assert.AreEqual(2, asyncEngine.LineNumber);

            Assert.IsTrue(rec1 != rec2);

            rec1 = (SampleType) asyncEngine.ReadNext();
            Assert.IsNotNull(rec2);
            Assert.AreEqual(3, asyncEngine.LineNumber);
            rec1 = (SampleType) asyncEngine.ReadNext();
            Assert.IsNotNull(rec2);
            Assert.AreEqual(4, asyncEngine.LineNumber);

            Assert.IsTrue(rec1 != rec2);

            Assert.AreEqual(4, asyncEngine.TotalRecords);
            Assert.AreEqual(0, asyncEngine.ErrorManager.ErrorCount);
        }

开发者ID:hoffmanc，项目名称:FileHelpers，代码行数:31，代码来源:LineCounter.cs

示例11: AsyncRead

        public void AsyncRead()
        {
            var asyncEngine = new FileHelperAsyncEngine<SampleType>();

            SampleType rec1, rec2;
            asyncEngine.BeginReadFile(FileTest.Good.Test1.Path);

            rec1 = asyncEngine.ReadNext();
            Assert.IsNotNull(rec1);
            rec2 = asyncEngine.ReadNext();
            Assert.IsNotNull(rec1);

            Assert.IsTrue(rec1 != rec2);

            rec1 = asyncEngine.ReadNext();
            Assert.IsNotNull(rec2);
            rec1 = asyncEngine.ReadNext();
            Assert.IsNotNull(rec2);

            Assert.IsTrue(rec1 != rec2);

            Assert.AreEqual(0, asyncEngine.ErrorManager.ErrorCount);

            asyncEngine.Close();
        }

开发者ID:rohancragg，项目名称:FileHelpers，代码行数:25，代码来源:ReadersGeneric.cs

示例12: ImportGeonamesFrom

        public void ImportGeonamesFrom(string fileName)
        {
            var geoNames = new FileHelperAsyncEngine(typeof(Geoname));
            geoNames.BeginReadFile(fileName);

            _geoDataStore.DeleteAll();

            long cnt = 0;
            foreach (Geoname geoName in geoNames)
            {
                //Store the name in a format suitable for case-insensitive searching:
                geoName.Name = geoName.Name.ToUpper();

                if (geoName.FeatureClass == "P")
                {
                    SaveCity(geoName, cnt);
                }

                // Parks: http://127.0.0.1:28017/local/geonames/?filter_FeatureClass=L&filter_FeatureCode=PRK
                if(geoName.FeatureClass.Equals("L") && geoName.FeatureCode.Equals("PRK"))
                {
                    SavePark(geoName);
                }

                cnt++;
            }

            _geoDataStore.DoIndexing();

            geoNames.Close();
        }

开发者ID:robertreppel，项目名称:Find-A-Park---Geospatial-searching-in-MongoDB，代码行数:31，代码来源:GeoDataImporter.cs

示例13: ReadWrite

        /// <summary>
        /// Process the delimited file twice,
        /// once with the simple engine, once with Async
        /// </summary>
        /// <remarks>
        /// This is a simple sample of using the Normal engine and the Async engine
        /// </remarks>
        public void ReadWrite()
        {
            var engine = new FileHelperEngine<Orders>();

            // to Read use:
            Orders[] res = engine.ReadFile(@"C:\TestIn.txt");

            // to Write use:
            engine.WriteFile(@"C:\TestOut.txt", res);

            foreach (Orders order in res) {
                Console.WriteLine("Order Info:");
                Console.WriteLine(order.CustomerID + " - " +
                                  order.OrderDate.ToString("dd/MM/yy"));
            }

            var asyncEngine = new FileHelperAsyncEngine<Orders>();

            asyncEngine.BeginReadFile(@"C:\TestIn.txt");

            Orders ord;

            while (asyncEngine.ReadNext() != null) {
                ord = asyncEngine.LastRecord;
                // your code here
                Console.WriteLine(ord.CustomerID);
            }
        }

开发者ID:mgmccarthy，项目名称:FileHelpers，代码行数:35，代码来源:EasySample.cs

示例14: Run

        //-> /File
        //->  Instantiate a FileHelperAsyncEngine and read or write files:
        public override void Run()
        {
            //-> File:Example.cs
            var engine = new FileHelperAsyncEngine<Customer>();

            // Read
            using(engine.BeginReadFile("Input.txt"))
            {
                // The engine is IEnumerable
                foreach(Customer cust in engine)
                {
                    // your code here
                    Console.WriteLine(cust.Name);
                }
            }

            // Write

            var arrayCustomers = new Customer[] {
                new Customer { CustId = 1732, Name = "Juan Perez", Balance = 435.00m,
                               AddedDate = new DateTime (2020, 5, 11) },
                new Customer { CustId = 554, Name = "Pedro Gomez", Balance = 12342.30m,
                               AddedDate = new DateTime (2004, 2, 6) },
            };

            using(engine.BeginWriteFile("TestOut.txt"))
            {
                foreach(Customer cust in arrayCustomers)
                {
                    engine.WriteNext(cust);
                }
            }

            //-> /File
        }

开发者ID:luksio，项目名称:FileHelpers，代码行数:37，代码来源:60.ReadWriteRecordByRecord.cs

示例15: WriteEvents

        public void WriteEvents()
        {
            before = 0;
            after = 0;

            engine = new FileHelperAsyncEngine<SampleType>();

            engine.BeforeWriteRecord += new BeforeWriteHandler<SampleType>(engine_BeforeWriteRecord);
            engine.AfterWriteRecord += new AfterWriteHandler<SampleType>(engine_AfterWriteRecord);

            var res = new SampleType[2];

            res[0] = new SampleType();
            res[1] = new SampleType();

            res[0].Field1 = DateTime.Now.AddDays(1);
            res[0].Field2 = "je";
            res[0].Field3 = 0;

            res[1].Field1 = DateTime.Now;
            res[1].Field2 = "ho";
            res[1].Field3 = 2;

            engine.BeginWriteFile("tempEvent.txt");
            engine.WriteNexts(res);
            engine.Close();

            File.Delete("tempEvent.txt");
            Assert.AreEqual(2, engine.TotalRecords);
            Assert.AreEqual(2, before);
            Assert.AreEqual(2, after);
        }

开发者ID:mgmccarthy，项目名称:FileHelpers，代码行数:32，代码来源:EventsAsync.cs

示例16: ExportApprovalList

        public void ExportApprovalList(string fileName, CancellationToken token)
        {
            using (DatabaseContext context = GetContext())
            {
                // init engine
                FileHelperAsyncEngine<CsvApprovalItem> engine = new FileHelperAsyncEngine<CsvApprovalItem>() { HeaderText = CsvApprovalItem.HeaderLine };
                engine.BeginWriteFile(fileName);

                // look for approval items
                var query = context.ViewApprovalLists.Where("[email protected]", new ObjectParameter("st", APPROVAL_STATUS_NEW));
                foreach (ViewApprovalList item in query)
                {
                    if (token.IsCancellationRequested) break;
                    engine.WriteNext(new CsvApprovalItem()
                    {
                        ItemID = item.Id,
                        EngineName = item.EngineName,
                        ProductName = item.SearchName,
                        FoundName = item.Name,
                        URL = item.Url,
                        Price = item.Price,
                        Command = APPROVAL_COMMAND_UNDEFINED
                    });
                }
                engine.Close();
            }
        }

开发者ID:Infarch，项目名称:MyPerlModules，代码行数:27，代码来源:DatabaseManager.cs

示例17: IgnoreComment1Async

        public void IgnoreComment1Async()
        {
            var asyncEngine = new FileHelperAsyncEngine<IgnoreCommentsType>();
            var res = TestCommon.ReadAllAsync<IgnoreCommentsType>(asyncEngine, "Good", "IgnoreComments1.txt");

            Assert.AreEqual(4, res.Count);
            Assert.AreEqual(7, asyncEngine.LineNumber);
        }

开发者ID:abombss，项目名称:FileHelpers，代码行数:8，代码来源:IgnoreEmpty.cs

示例18: IgnoreComment1Async

        public void IgnoreComment1Async()
        {
            asyncEngine = new FileHelperAsyncEngine(typeof (IgnoreCommentsType));
            object[] res = TestCommon.ReadAllAsync(asyncEngine, "Good", "IgnoreComments1.txt");

            Assert.AreEqual(4, res.Length);
            Assert.AreEqual(7, asyncEngine.LineNumber);
        }

开发者ID:hoffmanc，项目名称:FileHelpers，代码行数:8，代码来源:IgnoreEmpty.cs

示例19: NullRecords2

        public void NullRecords2()
        {
            engine2 = new FileHelperAsyncEngine(typeof (SampleType));
            engine2.BeginWriteStream(new StringWriter(new StringBuilder()));

            Assert.Throws<ArgumentNullException>(()
                => engine2.WriteNexts(null));
        }

开发者ID:hoffmanc，项目名称:FileHelpers，代码行数:8，代码来源:OtherErrors.cs

示例20: BeginWriteWhileReading

        public void BeginWriteWhileReading()
        {
            FileHelperAsyncEngine eng = new FileHelperAsyncEngine(typeof(SampleType));
            eng.BeginReadString("jejjeje");

            var filename = TestCommon.GetTempFile("TempWrite.txt");
            Assert.Throws<BadUsageException>(()
                => eng.BeginWriteFile(filename));
        }

开发者ID:TheJeremyGray，项目名称:FileWatcherService，代码行数:9，代码来源:ErrorModeValidatorAsync.cs

注：本文中的FileHelperAsyncEngine类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

C# FileHelperEngine类代码示例发布时间：2022-05-24

C# FileFormatVersions类代码示例发布时间：2022-05-24

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18011|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9587|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8136|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8520|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8424|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9323|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8387|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7820|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8375|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7369|2022-11-06

客服电话

电子邮件

C# FileHelperAsyncEngine类代码示例

示例1: RunAsyncConstructor

示例2: AsyncRead

示例3: AsyncFieldIndexBad2

示例4: RunAsyncConstructor

示例5: RunAsyncConstructor

示例6: AsyncFieldIndex1

示例7: Import

示例8: WriteNullAsync

示例9: AsyncRead

示例10: AsyncRead

示例11: AsyncRead

示例12: ImportGeonamesFrom

示例13: ReadWrite

示例14: Run

示例15: WriteEvents

示例16: ExportApprovalList

示例17: IgnoreComment1Async

示例18: IgnoreComment1Async

示例19: NullRecords2

示例20: BeginWriteWhileReading

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

如何使用MATLAB对任意三维数据绘制三维曲面

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053