Call ResetConsumedMessageSize from ReadMessageEndAsync
diff --git a/lib/netstd/Thrift/Protocol/TJSONProtocol.cs b/lib/netstd/Thrift/Protocol/TJSONProtocol.cs
index c100d86..82e758b 100644
--- a/lib/netstd/Thrift/Protocol/TJSONProtocol.cs
+++ b/lib/netstd/Thrift/Protocol/TJSONProtocol.cs
@@ -694,7 +694,9 @@
public override async Task ReadMessageEndAsync(CancellationToken cancellationToken)
{
+ cancellationToken.ThrowIfCancellationRequested();
await ReadJsonArrayEndAsync(cancellationToken);
+ Transport.ResetConsumedMessageSize();
}
public override async ValueTask<TStruct> ReadStructBeginAsync(CancellationToken cancellationToken)