@@ -409,8 +409,7 @@ private static ValueTask<Packet> ReadPacketAsync(BufferedByteReader bufferedByte
409
409
return ReadPacketAfterHeader ( headerBytesTask . Result , bufferedByteReader , byteHandler , getNextSequenceNumber , protocolErrorBehavior , ioBehavior ) ;
410
410
return AddContinuation ( headerBytesTask , bufferedByteReader , byteHandler , getNextSequenceNumber , protocolErrorBehavior , ioBehavior ) ;
411
411
412
- // NOTE: use a local function (with no captures) to defer creation of lambda objects
413
- ValueTask < Packet > AddContinuation ( ValueTask < ArraySegment < byte > > headerBytes_ , BufferedByteReader bufferedByteReader_ , IByteHandler byteHandler_ , Func < int > getNextSequenceNumber_ , ProtocolErrorBehavior protocolErrorBehavior_ , IOBehavior ioBehavior_ ) =>
412
+ static ValueTask < Packet > AddContinuation ( ValueTask < ArraySegment < byte > > headerBytes_ , BufferedByteReader bufferedByteReader_ , IByteHandler byteHandler_ , Func < int > getNextSequenceNumber_ , ProtocolErrorBehavior protocolErrorBehavior_ , IOBehavior ioBehavior_ ) =>
414
413
headerBytes_ . ContinueWith ( x => ReadPacketAfterHeader ( x , bufferedByteReader_ , byteHandler_ , getNextSequenceNumber_ , protocolErrorBehavior_ , ioBehavior_ ) ) ;
415
414
}
416
415
@@ -435,8 +434,7 @@ private static ValueTask<Packet> ReadPacketAfterHeader(ArraySegment<byte> header
435
434
return CreatePacketFromPayload ( payloadBytesTask . Result , payloadLength , protocolErrorBehavior , packetOutOfOrderException ) ;
436
435
return AddContinuation ( payloadBytesTask , payloadLength , protocolErrorBehavior , packetOutOfOrderException ) ;
437
436
438
- // NOTE: use a local function (with no captures) to defer creation of lambda objects
439
- ValueTask < Packet > AddContinuation ( ValueTask < ArraySegment < byte > > payloadBytesTask_ , int payloadLength_ , ProtocolErrorBehavior protocolErrorBehavior_ , Exception packetOutOfOrderException_ )
437
+ static ValueTask < Packet > AddContinuation ( ValueTask < ArraySegment < byte > > payloadBytesTask_ , int payloadLength_ , ProtocolErrorBehavior protocolErrorBehavior_ , Exception packetOutOfOrderException_ )
440
438
=> payloadBytesTask_ . ContinueWith ( x => CreatePacketFromPayload ( x , payloadLength_ , protocolErrorBehavior_ , packetOutOfOrderException_ ) ) ;
441
439
}
442
440
@@ -477,8 +475,7 @@ private static ValueTask<ArraySegment<byte>> DoReadPayloadAsync(BufferedByteRead
477
475
478
476
return AddContinuation ( readPacketTask , bufferedByteReader , byteHandler , getNextSequenceNumber , previousPayloads , protocolErrorBehavior , ioBehavior ) ;
479
477
480
- // NOTE: use a local function (with no captures) to defer creation of lambda objects
481
- ValueTask < ArraySegment < byte > > AddContinuation ( ValueTask < Packet > readPacketTask_ , BufferedByteReader bufferedByteReader_ , IByteHandler byteHandler_ , Func < int > getNextSequenceNumber_ , ArraySegmentHolder < byte > previousPayloads_ , ProtocolErrorBehavior protocolErrorBehavior_ , IOBehavior ioBehavior_ )
478
+ static ValueTask < ArraySegment < byte > > AddContinuation ( ValueTask < Packet > readPacketTask_ , BufferedByteReader bufferedByteReader_ , IByteHandler byteHandler_ , Func < int > getNextSequenceNumber_ , ArraySegmentHolder < byte > previousPayloads_ , ProtocolErrorBehavior protocolErrorBehavior_ , IOBehavior ioBehavior_ )
482
479
{
483
480
return readPacketTask_ . ContinueWith ( packet =>
484
481
HasReadPayload ( previousPayloads_ , packet , protocolErrorBehavior_ , out var result_ ) ? result_ :
@@ -518,8 +515,7 @@ public static ValueTask<int> WritePayloadAsync(IByteHandler byteHandler, Func<in
518
515
return payload . Count <= MaxPacketSize ? WritePacketAsync ( byteHandler , getNextSequenceNumber ( ) , payload , ioBehavior ) :
519
516
CreateTask ( byteHandler , getNextSequenceNumber , payload , ioBehavior ) ;
520
517
521
- // NOTE: use a local function (with no captures) to defer creation of lambda objects
522
- ValueTask < int > CreateTask ( IByteHandler byteHandler_ , Func < int > getNextSequenceNumber_ , ArraySegment < byte > payload_ , IOBehavior ioBehavior_ )
518
+ static ValueTask < int > CreateTask ( IByteHandler byteHandler_ , Func < int > getNextSequenceNumber_ , ArraySegment < byte > payload_ , IOBehavior ioBehavior_ )
523
519
{
524
520
var writeTask = default ( ValueTask < int > ) ;
525
521
for ( var bytesSent = 0 ; bytesSent < payload_ . Count ; bytesSent += MaxPacketSize )
@@ -546,8 +542,7 @@ private static ValueTask<int> WritePacketAsync(IByteHandler byteHandler, int seq
546
542
}
547
543
return AddContinuation ( task , buffer ) ;
548
544
549
- // NOTE: use a local function (with no captures) to defer creation of lambda objects
550
- ValueTask < int > AddContinuation ( ValueTask < int > task_ , byte [ ] buffer_ )
545
+ static ValueTask < int > AddContinuation ( ValueTask < int > task_ , byte [ ] buffer_ )
551
546
{
552
547
return task_ . ContinueWith ( x =>
553
548
{
0 commit comments