Merge pull request #6 from tpeczek/fix-request-n-read

Fix for Request N read
rsocket · Aug 31, 2019 · 1960d65 · 1960d65
2 parents ad99a3a + dd8d52e
commit 1960d65
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/RSocket.Core/RSocketProtocol.cs b/RSocket.Core/RSocketProtocol.cs
@@ -155,7 +155,7 @@ public RequestChannel(Int32 id, ReadOnlySequence<byte> data, ReadOnlySequence<by
 			public RequestChannel(in Header header, ref SequenceReader<byte> reader)
 			{
 				Header = header;
-				reader.TryRead(out int initialRequest); InitialRequest = initialRequest;
+				reader.TryReadBigEndian(out int initialRequest); InitialRequest = initialRequest;
 				TryReadRemaining(header, InnerLength, ref reader, out MetadataLength, out DataLength);
 			}
 
@@ -211,7 +211,7 @@ public RequestStream(Int32 id, ReadOnlySequence<byte> data, ReadOnlySequence<byt
 			public RequestStream(in Header header, ref SequenceReader<byte> reader)
 			{
 				Header = header;
-				reader.TryRead(out int initialRequest); InitialRequest = initialRequest;
+				reader.TryReadBigEndian(out int initialRequest); InitialRequest = initialRequest;
 				TryReadRemaining(header, InnerLength, ref reader, out MetadataLength, out DataLength);
 			}
 
@@ -359,7 +359,7 @@ public RequestN(Int32 id, ReadOnlySequence<byte> data, ReadOnlySequence<byte> me
 			public RequestN(in Header header, ref SequenceReader<byte> reader)
 			{
 				Header = header;
-				reader.TryRead(out int requestNumber); RequestNumber = requestNumber;
+				reader.TryReadBigEndian(out int requestNumber); RequestNumber = requestNumber;
 			}
 
 			public bool Validate(bool canContinue = false)