in src/MySqlAsyncEnumerable.cs [103:121]
private bool GetNextRow()
{
// check connection state before trying to access the reader
// if DisposeAsync has already closed it
if (this._connection.State != System.Data.ConnectionState.Closed)
{
if (this._reader == null)
{
MySqlCommand command = MySqlBindingUtilities.BuildCommand(this._attribute, this._connection);
this._reader = command.ExecuteReader();
}
if (this._reader.Read())
{
this.Current = Utils.JsonDeserializeObject<T>(this.SerializeRow());
return true;
}
}
return false;
}