tried to fix unit test

Author: kerryjiang

tests/Test/MainTest.cs

@@ -66,28 +66,19 @@ public async Task TestInsertEvent()
             cmd.CommandText = "INSERT INTO pet (name, owner, species, sex, birth, death, timeUpdated) values ('Rokie', 'Kerry', 'abc', 'F', '1992-05-20', '3000-01-01', now()); SELECT LAST_INSERT_ID();";
             var id = (UInt64)(await cmd.ExecuteScalarAsync());
 
-            while (true)
-            {
-                var eventLog = await _mysqlFixture.Client.ReceiveAsync();
-
-                if (eventLog.EventType == LogEventType.WRITE_ROWS_EVENT)
-                {
-                    var log = eventLog as WriteRowsEvent;
-                    Assert.NotNull(log);
+            var eventLog = await _mysqlFixture.ReceiveAsync<WriteRowsEvent>();
 
-                    var rows = log.RowSet.ToReadableRows();
-                    Assert.Equal(1, rows.Count);
+            Assert.NotNull(eventLog);
 
-                    var row = rows[0];
+            var rows = eventLog.RowSet.ToReadableRows();
+            Assert.Equal(1, rows.Count);
 
-                    Assert.Equal("Rokie", row["name"]);
-                    Assert.Equal("Kerry", row["owner"]);
-                    Assert.Equal("abc", row["species"]);
-                    Assert.Equal("F", row["sex"]);
+            var row = rows[0];
 
-                    break;
-                }
-            }
+            Assert.Equal("Rokie", row["name"]);
+            Assert.Equal("Kerry", row["owner"]);
+            Assert.Equal("abc", row["species"]);
+            Assert.Equal("F", row["sex"]);
         }
 
         [Fact]
@@ -123,35 +114,29 @@ public async Task TestUpdateEvent()
             cmd.CommandText = "update pet set owner='Linda', timeUpdated=now() where `id`=" + id;
             await cmd.ExecuteNonQueryAsync();
 
-            while (true)
-            {
-                var eventLog = await _mysqlFixture.Client.ReceiveAsync();
-
-                _outputHelper.WriteLine(eventLog.ToString() + "\r\n");
-                
-                if (eventLog.EventType == LogEventType.UPDATE_ROWS_EVENT)
-                {
-                    var log = eventLog as UpdateRowsEvent;
-                    Assert.NotNull(log);
+            var eventLog = await _mysqlFixture.ReceiveAsync<UpdateRowsEvent>();
 
-                    var rows = log.RowSet.ToReadableRows();
-                    Assert.Equal(1, rows.Count);
+            _outputHelper.WriteLine(eventLog.ToString() + "\r\n");
+            
+            if (eventLog.EventType == LogEventType.UPDATE_ROWS_EVENT)
+            {
+                Assert.NotNull(eventLog);
 
-                    var row = rows[0];
+                var rows = eventLog.RowSet.ToReadableRows();
+                Assert.Equal(1, rows.Count);
 
-                    var cellValue = row["id"] as CellValue;
+                var row = rows[0];
 
-                    Assert.Equal(id, cellValue.OldValue);
-                    Assert.Equal(id, cellValue.NewValue);
+                var cellValue = row["id"] as CellValue;
 
-                    cellValue = row["owner"] as CellValue;
+                Assert.Equal(id, cellValue.OldValue);
+                Assert.Equal(id, cellValue.NewValue);
 
-                    Assert.Equal("Kerry", oldValues["owner"]);
-                    Assert.Equal("Kerry", cellValue.OldValue);
-                    Assert.Equal("Linda", cellValue.NewValue);
+                cellValue = row["owner"] as CellValue;
 
-                    break;
-                }
+                Assert.Equal("Kerry", oldValues["owner"]);
+                Assert.Equal("Kerry", cellValue.OldValue);
+                Assert.Equal("Linda", cellValue.NewValue);
             }
         }
     }