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