From 51f144d09cebee9ca55b8b93510daaa9c520a066 Mon Sep 17 00:00:00 2001 From: joemphilips Date: Thu, 19 May 2022 18:58:20 +0900 Subject: [PATCH] stop using NamedPipeStream in test * Since it does not work in CI environment --- tests/DotNetLightning.ClnRpc.Tests/Tests.fs | 28 ++++----------------- 1 file changed, 5 insertions(+), 23 deletions(-) diff --git a/tests/DotNetLightning.ClnRpc.Tests/Tests.fs b/tests/DotNetLightning.ClnRpc.Tests/Tests.fs index f3e166577..f23d0e6e8 100644 --- a/tests/DotNetLightning.ClnRpc.Tests/Tests.fs +++ b/tests/DotNetLightning.ClnRpc.Tests/Tests.fs @@ -129,25 +129,11 @@ module TestHelpers = [] let PipeName = "SamplePipe1" - let serverPipe() = - new NamedPipeServerStream( - PipeName, - PipeDirection.InOut, - NamedPipeServerStream.MaxAllowedServerInstances, - PipeTransmissionMode.Byte, - PipeOptions.Asynchronous - ) - - let clientPipe() = - new NamedPipeClientStream( - ".", - PipeName, - PipeDirection.InOut, - PipeOptions.Asynchronous - ) + let struct (serverPipe, clientPipe) = + Nerdbank.Streams.FullDuplexStream.CreatePair() let inline getClientProxy<'T when 'T: not struct>() = - let pipe = clientPipe() + let pipe = clientPipe let handler = let formatter = new JsonMessageFormatter() @@ -158,16 +144,12 @@ module TestHelpers = new NewLineDelimitedMessageHandler(pipe, pipe, formatter) - task { - do! pipe.ConnectAsync() - return JsonRpc.Attach<'T>(handler) - } + task { return JsonRpc.Attach<'T>(handler) } let inline createRpcServer<'T when 'T: not struct>(server: 'T) = task { while true do - let pipe = serverPipe() - do! pipe.WaitForConnectionAsync() + let pipe = serverPipe let handler = let formatter = new JsonMessageFormatter()