Rename IKcpConversation.OnReceived to InputPakcetAsync

(cherry picked from commit ca5da23)

samples/KcpChatWasm/PerfectKcpConversationPipe.cs

@@ -83,7 +83,7 @@ async ValueTask IKcpTransport.SendPacketAsync(ReadOnlyMemory<byte> packet, Cance
 
         public async Task PutPacketAsync(byte[] packet, CancellationToken cancellationToken)
         {
-            await _conversation.OnReceivedAsync(packet, cancellationToken).ConfigureAwait(false);
+            await _conversation.InputPakcetAsync(packet, cancellationToken).ConfigureAwait(false);
         }
     }
 }

samples/KcpEcho/KcpEchoService.cs

@@ -30,7 +30,7 @@ ValueTask IKcpTransport.SendPacketAsync(ReadOnlyMemory<byte> packet, Cancellatio
             => _sender.SendPacketAsync(_endPoint, packet, cancellationToken);
 
         ValueTask IUdpService.InputPacketAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken)
-            => _conversation.OnReceivedAsync(packet, cancellationToken);
+            => _conversation.InputPakcetAsync(packet, cancellationToken);
 
         void IUdpService.SetTransportClosed()
             => _conversation.SetTransportClosed();

samples/KcpTunnel/KcpTunnelService.cs

@@ -35,7 +35,7 @@ ValueTask IUdpService.InputPacketAsync(ReadOnlyMemory<byte> packet, Cancellation
                     ProcessNewConnection(id);
                 }
             }
-            return _connection.OnReceivedAsync(packet, cancellationToken);
+            return _connection.InputPakcetAsync(packet, cancellationToken);
         }
 
         public void Start()

src/KcpSharp/IKcpConversation.cs

@@ -15,7 +15,7 @@ public interface IKcpConversation : IDisposable
         /// <param name="packet">The packet content with conversation ID.</param>
         /// <param name="cancellationToken">The token to cancel this operation.</param>
         /// <returns>A <see cref="ValueTask"/> that completes when the packet is put into the receive queue.</returns>
-        ValueTask OnReceivedAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken);
+        ValueTask InputPakcetAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken);
 
         /// <summary>
         /// Mark the underlying transport as closed. Abort all active send or receive operations.

src/KcpSharp/KcpConversation.cs

@@ -730,7 +730,7 @@ private bool HandleFlushException(Exception ex)
         }
 
         /// <inheritdoc />
-        public ValueTask OnReceivedAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken = default)
+        public ValueTask InputPakcetAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken = default)
         {
             if (cancellationToken.IsCancellationRequested)
             {

src/KcpSharp/KcpMultiplexConnection.cs

@@ -60,7 +60,7 @@ private static void ThrowObjectDisposedException()
         /// <param name="packet">The content of the packet with conversation ID.</param>
         /// <param name="cancellationToken">A token to cancel this operation.</param>
         /// <returns>A <see cref="ValueTask"/> that completes when the packet is handled by the corresponding channel or conversation.</returns>
-        public ValueTask OnReceivedAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken = default)
+        public ValueTask InputPakcetAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken = default)
         {
             ReadOnlySpan<byte> span = packet.Span;
             if (span.Length < 4)
@@ -74,7 +74,7 @@ public ValueTask OnReceivedAsync(ReadOnlyMemory<byte> packet, CancellationToken
             int id = (int)BinaryPrimitives.ReadUInt32LittleEndian(span);
             if (_conversations.TryGetValue(id, out (IKcpConversation Conversation, T? State) value))
             {
-                return value.Conversation.OnReceivedAsync(packet, cancellationToken);
+                return value.Conversation.InputPakcetAsync(packet, cancellationToken);
             }
             return default;
         }

src/KcpSharp/KcpRawChannel.cs

@@ -202,7 +202,7 @@ private bool HandleFlushException(Exception ex)
         }
 
         /// <inheritdoc />
-        public ValueTask OnReceivedAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken = default)
+        public ValueTask InputPakcetAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken = default)
         {
             ReadOnlySpan<byte> span = packet.Span;
             if (span.Length < 4 || span.Length > _mtu)

src/KcpSharp/KcpSocketTransportOfT.cs

@@ -241,7 +241,7 @@ private async Task RunReceiveLoopAsync(CancellationTokenSource cts)
 
                     if (bytesReceived != 0 && bytesReceived <= _mtu)
                     {
-                        await connection.OnReceivedAsync(memory.Slice(0, bytesReceived), cancellationToken).ConfigureAwait(false);
+                        await connection.InputPakcetAsync(memory.Slice(0, bytesReceived), cancellationToken).ConfigureAwait(false);
                     }
                 }
             }

tests/KcpSharp.Tests/Utils/BadKcpConversationPipe.cs

@@ -120,7 +120,7 @@ private async Task SendAsync(byte[] packet, CancellationToken cancellationToken)
 
         public async Task PutPacketAsync(byte[] packet, CancellationToken cancellationToken)
         {
-            await _conversation.OnReceivedAsync(packet, cancellationToken).ConfigureAwait(false);
+            await _conversation.InputPakcetAsync(packet, cancellationToken).ConfigureAwait(false);
         }
     }
 

tests/KcpSharp.Tests/Utils/KcpRawDuplexChannel.cs

@@ -97,7 +97,7 @@ async ValueTask IKcpTransport.SendPacketAsync(ReadOnlyMemory<byte> packet, Cance
 
         public async Task PutPacketAsync(byte[] packet, CancellationToken cancellationToken)
         {
-            await ((IKcpConversation)_conversation).OnReceivedAsync(packet, cancellationToken).ConfigureAwait(false);
+            await ((IKcpConversation)_conversation).InputPakcetAsync(packet, cancellationToken).ConfigureAwait(false);
         }
     }
 }

tests/KcpSharp.Tests/Utils/PerfectKcpConversationPipe.cs

@@ -80,7 +80,7 @@ async ValueTask IKcpTransport.SendPacketAsync(ReadOnlyMemory<byte> packet, Cance
 
         public async Task PutPacketAsync(byte[] packet, CancellationToken cancellationToken)
         {
-            await _conversation.OnReceivedAsync(packet, cancellationToken).ConfigureAwait(false);
+            await _conversation.InputPakcetAsync(packet, cancellationToken).ConfigureAwait(false);
         }
     }
 }

tests/KcpSharp.ThroughputBanchmarks/PacketsThroughputBenchmark/PacketsThroughputBenchmarkService.cs

@@ -29,7 +29,7 @@ ValueTask IKcpTransport.SendPacketAsync(ReadOnlyMemory<byte> packet, Cancellatio
             => _sender.SendPacketAsync(_endPoint, packet, cancellationToken);
 
         ValueTask IUdpService.InputPacketAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken)
-            => _conversation.OnReceivedAsync(packet, cancellationToken);
+            => _conversation.InputPakcetAsync(packet, cancellationToken);
 
         void IUdpService.SetTransportClosed()
             => _conversation.SetTransportClosed();

tests/KcpSharp.ThroughputBanchmarks/StreamThroughputBenchmark/StreamThroughputBenchmarkService.cs

@@ -29,7 +29,7 @@ ValueTask IKcpTransport.SendPacketAsync(ReadOnlyMemory<byte> packet, Cancellatio
             => _sender.SendPacketAsync(_endPoint, packet, cancellationToken);
 
         ValueTask IUdpService.InputPacketAsync(ReadOnlyMemory<byte> packet, CancellationToken cancellationToken)
-            => _conversation.OnReceivedAsync(packet, cancellationToken);
+            => _conversation.InputPakcetAsync(packet, cancellationToken);
 
         void IUdpService.SetTransportClosed()
             => _conversation.SetTransportClosed();