Skip to content

Commit f9143f8

Browse files
Update message broker service write message flushing
1 parent 1d8d644 commit f9143f8

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/CompilerStream/MessageBrokerService.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,8 @@ private void WriteMessage(CompilerMessage message)
9898
{
9999
Constants.Serializer.GetJsonSerializer().Serialize(streamWriter, message);
100100

101+
streamWriter.Flush();
102+
101103
int length = (int)memoryStream.Length;
102104
length.WriteBigEndian(headerBuffer);
103105

@@ -110,7 +112,6 @@ private void WriteMessage(CompilerMessage message)
110112
}
111113
finally
112114
{
113-
streamWriter.Flush();
114115
ArrayPool<byte>.Shared.Return(headerBuffer);
115116
}
116117
}

0 commit comments

Comments
 (0)