|
|
@ -42,7 +42,7 @@ namespace Grpc.Core.Internal |
|
|
|
public override byte[] PayloadAsNewBuffer() |
|
|
|
public override byte[] PayloadAsNewBuffer() |
|
|
|
{ |
|
|
|
{ |
|
|
|
var buffer = new byte[payloadLength]; |
|
|
|
var buffer = new byte[payloadLength]; |
|
|
|
FillContinguousBuffer(bufferReader, buffer); |
|
|
|
PayloadAsReadOnlySequence().CopyTo(buffer); |
|
|
|
return buffer; |
|
|
|
return buffer; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -72,10 +72,5 @@ namespace Grpc.Core.Internal |
|
|
|
instance.Initialize(bufferReader); |
|
|
|
instance.Initialize(bufferReader); |
|
|
|
return instance; |
|
|
|
return instance; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void FillContinguousBuffer(IBufferReader reader, byte[] destination) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
PayloadAsReadOnlySequence().CopyTo(new Span<byte>(destination)); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|