File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
src/Nerdbank.Streams.Tests Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -156,7 +156,13 @@ public void TryRead_FalseStillTurnsOnReadingMode()
156
156
[ Fact ]
157
157
public void TryRead_FalseCanBeCalledRepeatedly ( )
158
158
{
159
- var reader = this . CreatePipeReader ( new MemoryStream ( new byte [ ] { 1 , 2 , 3 } ) ) ;
159
+ // Arrange for the read stream to never respond so that the test doesn't randomly fail in the StreamUsePipeReaderTests derived test class.
160
+ var unblockReader = new ManualResetEventSlim ( ) ;
161
+ var slowReadStream = new MonitoringStream ( new MemoryStream ( new byte [ ] { 1 , 2 , 3 } ) ) ;
162
+ slowReadStream . WillReadMemory += ( s , e ) => unblockReader . Wait ( this . TimeoutToken ) ;
163
+ slowReadStream . WillRead += ( s , e ) => unblockReader . Wait ( this . TimeoutToken ) ;
164
+
165
+ var reader = this . CreatePipeReader ( slowReadStream ) ;
160
166
161
167
// Verify that it's safe to call TryRead repeatedly when it returns False.
162
168
Assert . False ( reader . TryRead ( out var readResult ) ) ;
You can’t perform that action at this time.
0 commit comments