From d8af0bbc11981522e304ca5346179dce021951fc Mon Sep 17 00:00:00 2001 From: Luke Butters Date: Wed, 26 Jul 2023 13:05:28 +1000 Subject: [PATCH 1/2] A problem --- source/Halibut.Tests/Halibut.Tests.csproj | 2 +- source/Halibut.Tests/UsageFixture.cs | 3 ++- source/Halibut/Transport/Protocol/MessageExchangeStream.cs | 7 +++++-- 3 files changed, 8 insertions(+), 4 deletions(-) diff --git a/source/Halibut.Tests/Halibut.Tests.csproj b/source/Halibut.Tests/Halibut.Tests.csproj index ffc36306b..14c4f6857 100644 --- a/source/Halibut.Tests/Halibut.Tests.csproj +++ b/source/Halibut.Tests/Halibut.Tests.csproj @@ -10,7 +10,7 @@ enable - net48;net6.0 + net48 net6.0 diff --git a/source/Halibut.Tests/UsageFixture.cs b/source/Halibut.Tests/UsageFixture.cs index 8a2417d74..384000636 100644 --- a/source/Halibut.Tests/UsageFixture.cs +++ b/source/Halibut.Tests/UsageFixture.cs @@ -81,7 +81,8 @@ public async Task OctopusCanSendMessagesToTentacle_WithSupportedServices(ClientA } [Test] - [LatestAndPreviousClientAndServiceVersionsTestCases] + //[LatestAndPreviousClientAndServiceVersionsTestCases()] + [LatestClientAndLatestServiceTestCases()] [FailedWebSocketTestsBecomeInconclusive] public async Task StreamsCanBeSent(ClientAndServiceTestCase clientAndServiceTestCase) { diff --git a/source/Halibut/Transport/Protocol/MessageExchangeStream.cs b/source/Halibut/Transport/Protocol/MessageExchangeStream.cs index 6adeed809..03156d8a2 100644 --- a/source/Halibut/Transport/Protocol/MessageExchangeStream.cs +++ b/source/Halibut/Transport/Protocol/MessageExchangeStream.cs @@ -182,10 +182,13 @@ public RemoteIdentity ReadRemoteIdentity() public void Send(T message) { + Stream stream = this.stream; + stream = new BufferedStream(stream, 10000000); using (var capture = StreamCapture.New()) { serializer.WriteMessage(stream, message); - WriteEachStream(capture.SerializedStreams); + WriteEachStream(capture.SerializedStreams, stream); + stream.Flush(); } log.Write(EventType.Diagnostic, "Sent: {0}", message); @@ -275,7 +278,7 @@ static DataStream FindStreamById(StreamCapture capture, Guid id) return dataStream; } - void WriteEachStream(IEnumerable streams) + void WriteEachStream(IEnumerable streams, Stream stream) { foreach (var dataStream in streams) { From daa4529a23b5a9b836796571f9431e2c79f67b3d Mon Sep 17 00:00:00 2001 From: Stephen Burman Date: Wed, 26 Jul 2023 13:56:15 +1000 Subject: [PATCH 2/2] . --- source/Halibut.Tests/Halibut.Tests.csproj | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/Halibut.Tests/Halibut.Tests.csproj b/source/Halibut.Tests/Halibut.Tests.csproj index 14c4f6857..58133f89e 100644 --- a/source/Halibut.Tests/Halibut.Tests.csproj +++ b/source/Halibut.Tests/Halibut.Tests.csproj @@ -10,7 +10,7 @@ enable - net48 + net48;net6.0 net6.0