Merge pull request #73 from y-crdt/move-protocol

Move protocol extensions to root project.
y-crdt · Jan 11, 2024 · 04f798e · 04f798e
2 parents 229fd82 + b79d3dd
commit 04f798e
Show file tree

Hide file tree

Showing 13 changed files with 523 additions and 202 deletions.
diff --git a/YDotNet.Server.Redis/RedisDocumentStorage.cs b/YDotNet.Server.Redis/RedisDocumentStorage.cs
@@ -24,7 +24,8 @@ private async Task InitializeAsync(RedisConnection redisConnection)
         database = connection.GetDatabase(redisOptions.Database);
     }
 
-    public async ValueTask<byte[]?> GetDocAsync(string name,
+    public async ValueTask<byte[]?> GetDocAsync(
+        string name,
         CancellationToken ct = default)
     {
         if (database == null)

diff --git a/YDotNet.Server.WebSockets/EncoderExtensions.cs b/YDotNet.Server.WebSockets/EncoderExtensions.cs
diff --git a/YDotNet.Server.WebSockets/MessageTypes.cs b/YDotNet.Server.WebSockets/MessageTypes.cs
diff --git a/YDotNet.Server.WebSockets/WebSocketEncoder.cs b/YDotNet.Server.WebSockets/WebSocketEncoder.cs
@@ -17,6 +17,11 @@ public void Dispose()
     {
     }
 
+    public override ValueTask FlushAsync(CancellationToken ct = default)
+    {
+        return new ValueTask(webSocket.SendAsync(Array.Empty<byte>(), WebSocketMessageType.Binary, true, ct));
+    }
+
     protected override ValueTask WriteByteAsync(byte value, CancellationToken ct)
     {
         buffer[0] = value;
@@ -28,9 +33,4 @@ protected override ValueTask WriteBytesAsync(ArraySegment<byte> bytes, Cancellat
     {
         return new ValueTask(webSocket.SendAsync(bytes, WebSocketMessageType.Binary, false, ct));
     }
-
-    public ValueTask FlushAsync(CancellationToken ct = default)
-    {
-        return new ValueTask(webSocket.SendAsync(Array.Empty<byte>(), WebSocketMessageType.Binary, true, ct));
-    }
 }