AsStream() is very necessary since it must flush the data

lukebakken · lukebakken · commit 390d503af4c8 · 2023-03-01T09:10:33.000-08:00
diff --git a/projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs b/projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs
@@ -250,7 +250,11 @@ public bool TryReadFrame(out InboundFrame frame)
 
         public void SendHeader()
         {
-            _pipeWriter.Write(ProtocolHeader);
+#if NET
+            _pipeWriter.AsStream().Write(ProtocolHeader);
+#else
+            _pipeWriter.AsStream().Write(ProtocolHeader.ToArray(), 0, ProtocolHeader.Length);
+#endif
         }
 
         public void Write(ReadOnlyMemory<byte> memory)

Original file line number	Diff line number	Diff line change
`@@ -250,7 +250,11 @@ public bool TryReadFrame(out InboundFrame frame)`
`250`	`250`
`251`	`251`	`public void SendHeader()`
`252`	`252`	`{`
`253`		`- _pipeWriter.Write(ProtocolHeader);`
	`253`	`+#if NET`
	`254`	`+ _pipeWriter.AsStream().Write(ProtocolHeader);`
	`255`	`+#else`
	`256`	`+ _pipeWriter.AsStream().Write(ProtocolHeader.ToArray(), 0, ProtocolHeader.Length);`
	`257`	`+#endif`
`254`	`258`	`}`
`255`	`259`
`256`	`260`	`public void Write(ReadOnlyMemory<byte> memory)`