@@ -38,7 +38,7 @@ public void CancelCommand()
38
38
task . Wait ( ) ; // shouldn't throw
39
39
}
40
40
41
- [ SkippableFact ( ServerFeatures . Timeout ) ]
41
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
42
42
public void CancelReaderAsynchronously ( )
43
43
{
44
44
using var barrier = new Barrier ( 2 ) ;
@@ -72,7 +72,7 @@ public void CancelReaderAsynchronously()
72
72
task . Wait ( ) ; // shouldn't throw
73
73
}
74
74
75
- [ SkippableFact ( ServerFeatures . Timeout ) ]
75
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
76
76
public void CancelCommandBeforeRead ( )
77
77
{
78
78
using var cmd = new MySqlCommand ( c_hugeQuery , m_database . Connection ) ;
@@ -95,7 +95,7 @@ public void CancelCommandBeforeRead()
95
95
Assert . InRange ( rows , 0 , 10000000 ) ;
96
96
}
97
97
98
- [ SkippableFact ( ServerFeatures . Timeout , Baseline = "Hangs in NextResult" ) ]
98
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout , Baseline = "Hangs in NextResult" ) ]
99
99
public void CancelMultiStatementReader ( )
100
100
{
101
101
using var barrier = new Barrier ( 2 ) ;
@@ -131,7 +131,7 @@ public void CancelMultiStatementReader()
131
131
task . Wait ( ) ; // shouldn't throw
132
132
}
133
133
134
- [ SkippableFact ( ServerFeatures . Timeout ) ]
134
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
135
135
public void DapperQueryMultiple ( )
136
136
{
137
137
Stopwatch stopwatch ;
@@ -241,7 +241,7 @@ public void ImplicitCancelWithDapper()
241
241
Assert . Equal ( "value" , value ) ;
242
242
}
243
243
244
- [ SkippableFact ( ServerFeatures . Timeout ) ]
244
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
245
245
public async Task CancelHugeQueryWithTokenAfterExecuteReader ( )
246
246
{
247
247
using var cmd = new MySqlCommand ( c_hugeQuery , m_database . Connection ) ;
@@ -265,7 +265,7 @@ public async Task CancelHugeQueryWithTokenAfterExecuteReader()
265
265
Assert . False ( reader . NextResult ( ) ) ;
266
266
}
267
267
268
- [ SkippableFact ( ServerFeatures . Timeout ) ]
268
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
269
269
public async Task CancelHugeQueryWithTokenInNextResult ( )
270
270
{
271
271
using var cmd = new MySqlCommand ( c_hugeQuery + "select 1, 2, 3;" , m_database . Connection ) ;
@@ -354,7 +354,7 @@ public async Task CancelSlowQueryWithTokenAfterNextResult()
354
354
Assert . False ( await reader . NextResultAsync ( ) ) ;
355
355
}
356
356
357
- [ SkippableFact ( ServerFeatures . Timeout ) ]
357
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
358
358
public async Task CancelMultiStatementInRead ( )
359
359
{
360
360
using var cmd = new MySqlCommand ( c_hugeQuery + c_hugeQuery + c_hugeQuery , m_database . Connection ) ;
@@ -403,7 +403,7 @@ public void CancelBatchCommand()
403
403
task . Wait ( ) ; // shouldn't throw
404
404
}
405
405
406
- [ SkippableFact ( ServerFeatures . Timeout ) ]
406
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
407
407
public void CancelBatchReaderAsynchronously ( )
408
408
{
409
409
using var barrier = new Barrier ( 2 ) ;
@@ -443,7 +443,7 @@ public void CancelBatchReaderAsynchronously()
443
443
task . Wait ( ) ; // shouldn't throw
444
444
}
445
445
446
- [ SkippableFact ( ServerFeatures . Timeout ) ]
446
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
447
447
public void CancelBatchBeforeRead ( )
448
448
{
449
449
using var batch = new MySqlBatch ( m_database . Connection )
@@ -472,7 +472,7 @@ public void CancelBatchBeforeRead()
472
472
Assert . InRange ( rows , 0 , 10000000 ) ;
473
473
}
474
474
475
- [ SkippableFact ( ServerFeatures . Timeout , Skip = "COM_MULTI" ) ]
475
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout , Skip = "COM_MULTI" ) ]
476
476
public void CancelMultiCommandBatchReader ( )
477
477
{
478
478
using var barrier = new Barrier ( 2 ) ;
@@ -611,7 +611,7 @@ value varchar(45)
611
611
}
612
612
}
613
613
614
- [ SkippableFact ( ServerFeatures . Timeout ) ]
614
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout ) ]
615
615
public async Task CancelHugeQueryBatchWithTokenAfterExecuteReader ( )
616
616
{
617
617
using var batch = new MySqlBatch ( m_database . Connection )
@@ -641,7 +641,7 @@ public async Task CancelHugeQueryBatchWithTokenAfterExecuteReader()
641
641
Assert . False ( reader . NextResult ( ) ) ;
642
642
}
643
643
644
- [ SkippableFact ( ServerFeatures . Timeout , Skip = "COM_MULTI" ) ]
644
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout , Skip = "COM_MULTI" ) ]
645
645
public async Task CancelHugeQueryBatchWithTokenInNextResult ( )
646
646
{
647
647
using var batch = new MySqlBatch ( m_database . Connection )
@@ -750,7 +750,7 @@ public async Task CancelSlowQueryBatchWithTokenAfterNextResult()
750
750
Assert . False ( await reader . NextResultAsync ( ) ) ;
751
751
}
752
752
753
- [ SkippableFact ( ServerFeatures . Timeout , Skip = "COM_MULTI" ) ]
753
+ [ SkippableFact ( ServerFeatures . StreamingResults | ServerFeatures . Timeout , Skip = "COM_MULTI" ) ]
754
754
public async Task CancelMultiStatementBatchInRead ( )
755
755
{
756
756
using var batch = new MySqlBatch ( m_database . Connection )
0 commit comments