@@ -22,7 +22,7 @@ namespace CouchDB.Driver
2222 public class CouchDatabase < TSource > where TSource : CouchDocument
2323 {
2424 private readonly QueryProvider _queryProvider ;
25- private readonly FlurlClient _flurlClient ;
25+ private readonly IFlurlClient _flurlClient ;
2626 private readonly CouchSettings _settings ;
2727 private readonly string _connectionString ;
2828
@@ -36,7 +36,7 @@ public class CouchDatabase<TSource> where TSource : CouchDocument
3636 /// </summary>
3737 public CouchSecurity Security { get ; }
3838
39- internal CouchDatabase ( FlurlClient flurlClient , CouchSettings settings , string connectionString , string db )
39+ internal CouchDatabase ( IFlurlClient flurlClient , CouchSettings settings , string connectionString , string db )
4040 {
4141 _flurlClient = flurlClient ?? throw new ArgumentNullException ( nameof ( flurlClient ) ) ;
4242 _settings = settings ?? throw new ArgumentNullException ( nameof ( settings ) ) ;
@@ -262,12 +262,12 @@ public Task<List<TSource>> QueryAsync(object mangoQuery)
262262
263263 private async Task < List < TSource > > SendQueryAsync ( Func < IFlurlRequest , Task < HttpResponseMessage > > requestFunc )
264264 {
265- var request = NewRequest ( )
265+ IFlurlRequest request = NewRequest ( )
266266 . AppendPathSegment ( "_find" ) ;
267267
268- var message = requestFunc ( request ) ;
268+ Task < HttpResponseMessage > message = requestFunc ( request ) ;
269269
270- var findResult = await message
270+ FindResult < TSource > findResult = await message
271271 . ReceiveJson < FindResult < TSource > > ( )
272272 . SendRequestAsync ( )
273273 . ConfigureAwait ( false ) ;
@@ -281,7 +281,7 @@ private async Task<List<TSource>> SendQueryAsync(Func<IFlurlRequest, Task<HttpRe
281281 /// <returns></returns>
282282 public async Task < List < TSource > > FindManyAsync ( IEnumerable < string > docIds )
283283 {
284- var bulkGetResult = await NewRequest ( )
284+ BulkGetResult < TSource > bulkGetResult = await NewRequest ( )
285285 . AppendPathSegment ( "_bulk_get" )
286286 . PostJsonAsync ( new
287287 {
0 commit comments