diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs index f5fc3a2d6..6ccb9a165 100644 --- a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs +++ b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs @@ -91,16 +91,12 @@ namespace MongoDb.Ado.data var collection = GetCollection(collectionName); return new ExecuteScalarHandlerAsync().HandleAsync(operation, collection, json); } - public override Task ExecuteReaderAsync(CancellationToken cancellationToken) + protected override Task ExecuteDbDataReaderAsync(CommandBehavior behavior,CancellationToken cancellationToken) { var (operation, collectionName, json) = ParseCommand(_commandText); var collection = GetCollection(collectionName); return new DbDataReaderFactoryAsync().HandleAsync(operation, collection, json); } - protected override Task ExecuteDbDataReaderAsync(CommandBehavior behavior,CancellationToken cancellationToken) - { - return ExecuteReaderAsync(); - } public override void Prepare() { }