1 write to _namedPipeClientStream
dotnet.Tests (1)
CommandTests\Test\NamedPipeClient.cs (1)
23
_namedPipeClientStream
= new(".", name, PipeDirection.InOut, PipeOptions.CurrentUserOnly);
6 references to _namedPipeClientStream
dotnet.Tests (6)
CommandTests\Test\NamedPipeClient.cs (6)
30
=> await
_namedPipeClientStream
.ConnectAsync(cancellationToken).ConfigureAwait(false);
93
await
_namedPipeClientStream
.WriteAsync(_messageBuffer.GetBuffer().AsMemory(0, (int)_messageBuffer.Position), cancellationToken).ConfigureAwait(false);
94
await
_namedPipeClientStream
.FlushAsync(cancellationToken).ConfigureAwait(false);
97
_namedPipeClientStream
.WaitForPipeDrain();
113
int currentReadBytes = await
_namedPipeClientStream
.ReadAsync(_readBuffer.AsMemory(currentReadIndex, _readBuffer.Length), cancellationToken).ConfigureAwait(false);
187
_namedPipeClientStream
.Dispose();