Skip to content

Commit

Permalink
Green build
Browse files Browse the repository at this point in the history
  • Loading branch information
Evangelink committed Feb 18, 2025
1 parent 9698588 commit a9094ac
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ public async Task SingleConnectionNamedPipeServer_RequestReplySerialization_Succ
});
NamedPipeServer singleConnectionNamedPipeServer = new(
pipeNameDescription,
(IRequest request) =>
request =>
{
receivedMessages.Enqueue((BaseMessage)request);
return Task.FromResult<IResponse>(VoidResponse.CachedInstance);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,8 @@ public ServerTests()
}
}

private static bool IsHotReloadEnabled(SystemEnvironment environment) => environment.GetEnvironmentVariable(EnvironmentVariableConstants.DOTNET_WATCH) == "1"
private static bool IsHotReloadEnabled(SystemEnvironment environment)
=> environment.GetEnvironmentVariable(EnvironmentVariableConstants.DOTNET_WATCH) == "1"
|| environment.GetEnvironmentVariable(EnvironmentVariableConstants.TESTINGPLATFORM_HOTRELOAD_ENABLED) == "1";

[TestMethod]
Expand Down Expand Up @@ -100,7 +101,7 @@ await WriteMessageAsync(
CancellationToken cancellationToken = cancellationTokenSource.Token;
try
{
msg = await WaitForMessage(messageHandler, (RpcMessage? rpcMessage) => rpcMessage is ResponseMessage, "Wait initialize", cancellationToken);
msg = await WaitForMessage(messageHandler, rpcMessage => rpcMessage is ResponseMessage, "Wait initialize", cancellationToken);
}
catch (OperationCanceledException ex) when (ex.CancellationToken == cancellationToken)
{
Expand Down Expand Up @@ -138,7 +139,7 @@ public async Task DiscoveryRequestCanBeCanceled()
ITestApplicationBuilder builder = await TestApplication.CreateBuilderAsync(args);
builder.RegisterTestFramework(_ => new TestFrameworkCapabilities(), (_, __) => new MockTestAdapter
{
DiscoveryAction = async (ExecuteRequestContext context) =>
DiscoveryAction = async context =>
{
using (context.CancellationToken.Register(() => discoveryCanceledTaskCompletionSource.SetResult(true)))
{
Expand Down Expand Up @@ -181,7 +182,7 @@ public async Task DiscoveryRequestCanBeCanceled()

// Wait for initialize response
using CancellationTokenSource cancellationTokenSource = new(TimeoutHelper.DefaultHangTimeSpanTimeout);
await WaitForMessage(messageHandler, (RpcMessage? rpcMessage) => rpcMessage is ResponseMessage, "Wait initialize", cancellationTokenSource.Token);
await WaitForMessage(messageHandler, rpcMessage => rpcMessage is ResponseMessage, "Wait initialize", cancellationTokenSource.Token);

RpcMessage? msg;

Expand Down Expand Up @@ -210,7 +211,7 @@ public async Task DiscoveryRequestCanBeCanceled()
await WriteMessageAsync(writer, cancelRequestMessage);

using CancellationTokenSource cancellationTokenSource2 = new(TimeoutHelper.DefaultHangTimeSpanTimeout);
msg = await WaitForMessage(messageHandler, (RpcMessage? rpcMessage) => rpcMessage is ErrorMessage, "Wait cancelRequest", cancellationTokenSource.Token);
msg = await WaitForMessage(messageHandler, rpcMessage => rpcMessage is ErrorMessage, "Wait cancelRequest", cancellationTokenSource.Token);

var error = (ErrorMessage)msg!;
Assert.AreEqual(ErrorCodes.RequestCanceled, error.ErrorCode);
Expand Down

0 comments on commit a9094ac

Please sign in to comment.