wip: 临时提交

Author: ArgoZhang

src/components/BootstrapBlazor.Term/Components/Term.razor.cs

@@ -155,12 +155,20 @@ private async Task LoopRead(Stream stream)
             var buffer = memoryOwner.Memory;
             while (_cancellationTokenSource is { IsCancellationRequested: false })
             {
-                var length = await stream.ReadAsync(buffer, _cancellationTokenSource.Token);
-                if (length == 0)
+                if (stream is { CanRead: true })
+                {
+                    var length = await stream.ReadAsync(buffer, _cancellationTokenSource.Token);
+                    if (length == 0)
+                    {
+                        await Task.Delay(50);
+                        continue;
+                    }
+                    await Write(buffer.Slice(0, length).ToArray());
+                }
+                else
                 {
                     break;
                 }
-                await Write(buffer.Slice(0, length));
             }
         }
         catch (OperationCanceledException)
@@ -179,7 +187,7 @@ private async Task LoopRead(Stream stream)
     /// </summary>
     /// <param name="data"></param>
     [JSInvokable]
-    public async Task OnDataAsync(byte[] data)
+    public async Task TriggerReceiveDataAsync(byte[] data)
     {
         if (_stream is { CanWrite: true })
         {
@@ -200,7 +208,7 @@ public async Task OnDataAsync(byte[] data)
     /// <param name="rows"></param>
     /// <param name="cols"></param>
     [JSInvokable]
-    public async Task OnResizeAsync(int rows, int cols)
+    public async Task TriggerResizeAsync(int rows, int cols)
     {
         Rows = rows;
         Columns = cols;

src/components/BootstrapBlazor.Term/Components/Term.razor.js

@@ -28,11 +28,13 @@ export async function init(id, invoke, options) {
 
     const encoder = new TextEncoder();
     term.onData(data => {
-        invoke.invokeMethodAsync("OnDataAsync", encoder.encode(data));
+        el.term.write(data);
+        console.log(data);
+        //invoke.invokeMethodAsync("TriggerReceiveDataAsync", encoder.encode(data));
     });
 
     term.onResize(size => {
-        invoke.invokeMethodAsync("OnResizeAsync", size.rows, size.cols);
+        invoke.invokeMethodAsync("TriggerResizeAsync", size.rows, size.cols);
     });
 
     el.term = term;
@@ -44,7 +46,7 @@ export async function init(id, invoke, options) {
             fitAddon.fit();
             const dims = fitAddon.proposeDimensions();
             if (dims) {
-                invoke.invokeMethodAsync("OnResizeAsync", dims.rows, dims.cols);
+                invoke.invokeMethodAsync("TriggerResizeAsync", dims.rows, dims.cols);
             }
         } catch (e) { }
     };