CommandTests\Test\NamedPipeClient.cs (14)
46_messageBuffer.Position = 0;
60await _messageBuffer.WriteAsync(bytes.AsMemory(0, sizeof(int)), cancellationToken).ConfigureAwait(false);
72await _messageBuffer.WriteAsync(bytes.AsMemory(0, sizeof(int)), cancellationToken).ConfigureAwait(false);
82await _messageBuffer.WriteAsync(_serializationBuffer.GetBuffer().AsMemory(0, (int)_serializationBuffer.Position), cancellationToken).ConfigureAwait(false);
93await _namedPipeClientStream.WriteAsync(_messageBuffer.GetBuffer().AsMemory(0, (int)_messageBuffer.Position), cancellationToken).ConfigureAwait(false);
103_messageBuffer.Position = 0;
141await _messageBuffer.WriteAsync(_readBuffer.AsMemory(currentReadIndex, missingBytesToReadOfCurrentChunk), cancellationToken).ConfigureAwait(false);
149_messageBuffer.Position = 0;
152int serializerId = BitConverter.ToInt32(_messageBuffer.GetBuffer(), 0);
155_messageBuffer.Position += sizeof(int); // Skip the serializer id
161return (TResponse)responseNamedPipeSerializer.Deserialize(_messageBuffer);
166_messageBuffer.Position = 0;
186_messageBuffer.Dispose();