MessageFraming is default package manager, Delete Package.cs and Pack…

…ageTest.cs. Implement MessageFramingTest
alec1o · Aug 30, 2023 · 8ec511d · 8ec511d
1 parent f31fc92
commit 8ec511d
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 91 deletions.
diff --git a/src/Core/Package.cs b/src/Core/Package.cs
diff --git a/src/Netly.csproj b/src/Netly.csproj
@@ -25,7 +25,7 @@
 		<PackageReadmeFile>README.md</PackageReadmeFile>
 		<PackageLicenseFile>LICENSE.md</PackageLicenseFile>
 		<PackageReleaseNotes>
-			+ Update default MAX_SIZE 8kb to 8MB (Package.MAX_SIZE -> MesssageFraming encode/decode)
+			+ Update default MAX_SIZE 8kb to 8MB (Package.MAX_SIZE -&gt; MesssageFraming encode/decode)
 		</PackageReleaseNotes>
 		<Description>
 			Netly is a socket library for c# (C-Sharp). It facilitates the use of socket (UDP and TCP, Client and Server).

diff --git a/test/PackageTest.cs → test/MessageFramingTest.cs b/test/PackageTest.cs → test/MessageFramingTest.cs
@@ -1,10 +1,17 @@
 using Netly.Abstract;
 using Netly.Core;
+using Xunit.Abstractions;
 
 namespace test;
 
-public class PackageTest
+public class MessageFramingTest
 {
+    private readonly ITestOutputHelper _testOutputHelper;
+    public MessageFramingTest(ITestOutputHelper testOutputHelper)
+    {
+        _testOutputHelper = testOutputHelper;
+    }
+
     [Fact]
     public void EndToEnd()
     {
@@ -20,11 +27,11 @@ public void EndToEnd()
 
         bool isLast = false;
 
-        byte[] buffer = new List<byte[]> { size1, value1, size2 }.SelectMany(x => x).ToArray();
+        byte[] buffer = new List<byte[]> { MessageFraming.PREFIX, size1, value1, MessageFraming.PREFIX, size2 }.SelectMany(x => x).ToArray();
 
-        Package package = new Package();
+        MessageFraming package = new MessageFraming();
 
-        package.Output((data) =>
+        package.OnData((data) =>
         {
             if (isLast is false)
             {
@@ -39,9 +46,14 @@ public void EndToEnd()
 
             isLast = !isLast;
         });
+
+        package.OnError((error) =>
+        {
+            _testOutputHelper.WriteLine($"OnError: {error}");
+        });
 
-        package.Input(buffer);
-        package.Input(value2);
+        package.Add(buffer);
+        package.Add(value2);
 
         Assert.Equal(value1, result1);
         Assert.Equal(value2, result2);