1 instantiation of RemoteJSDataStream
Microsoft.AspNetCore.Components.Server (1)
Circuits\RemoteJSDataStream.cs (1)
53var remoteJSDataStream = new RemoteJSDataStream(runtime, streamId, totalLength, chunkSize, jsInteropDefaultCallTimeout, cancellationToken);
41 references to RemoteJSDataStream
Microsoft.AspNetCore.Components.Server (6)
Circuits\CircuitHost.cs (1)
486return RemoteJSDataStream.ReceiveData(JSRuntime, streamId, chunkId, chunk, error);
Circuits\RemoteJSDataStream.cs (3)
26if (!runtime.RemoteJSDataStreamInstances.TryGetValue(streamId, out var instance)) 36public static async ValueTask<RemoteJSDataStream> CreateRemoteJSDataStreamAsync( 53var remoteJSDataStream = new RemoteJSDataStream(runtime, streamId, totalLength, chunkSize, jsInteropDefaultCallTimeout, cancellationToken);
Circuits\RemoteJSRuntime.cs (2)
27internal readonly Dictionary<long, RemoteJSDataStream> RemoteJSDataStreamInstances = new(); 227=> await RemoteJSDataStream.CreateRemoteJSDataStreamAsync(this, jsStreamReference, totalLength, _maximumIncomingBytes, _options.JSInteropDefaultCallTimeout, cancellationToken);
Microsoft.AspNetCore.Components.Server.Tests (35)
Circuits\RemoteJSDataStreamTest.cs (35)
24var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync(_jsRuntime, jsStreamReference, totalLength: 100, signalRMaximumIncomingBytes: 10_000, jsInteropDefaultCallTimeout: TimeSpan.FromMinutes(1), cancellationToken: CancellationToken.None).DefaultTimeout(); 38var success = await RemoteJSDataStream.ReceiveData(_jsRuntime, streamId: unrecognizedGuid, chunkId: 0, chunk, error: null).DefaultTimeout(); 49var remoteJSDataStream = await CreateRemoteJSDataStreamAsync(jsRuntime); 58var success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout(); 77var remoteJSDataStream = await CreateRemoteJSDataStreamAsync(jsRuntime); 86var success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout(); 105var remoteJSDataStream = await CreateRemoteJSDataStreamAsync(jsRuntime); 109var success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk: null, error: "some error").DefaultTimeout(); 123var remoteJSDataStream = await CreateRemoteJSDataStreamAsync(jsRuntime); 128var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout()); 142var remoteJSDataStream = await CreateRemoteJSDataStreamAsync(jsRuntime); 147var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout()); 162var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync(jsRuntime, jsStreamReference, totalLength: 100, signalRMaximumIncomingBytes: 10_000, jsInteropDefaultCallTimeout: TimeSpan.FromMinutes(1), cancellationToken: CancellationToken.None); 167var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout()); 182var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync(jsRuntime, jsStreamReference, totalLength: 100, signalRMaximumIncomingBytes: 10_000, jsInteropDefaultCallTimeout: TimeSpan.FromMinutes(1), cancellationToken: CancellationToken.None); 189await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: i, chunk, error: null); 191var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 7, chunk, error: null).DefaultTimeout()); 213var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync( 237var success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout(); 254var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync( 265var success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 0, chunk, error: null).DefaultTimeout(); 269success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 1, chunk, error: null).DefaultTimeout(); 286success = await RemoteJSDataStream.ReceiveData(jsRuntime, streamId, chunkId: 2, chunk, error: null).DefaultTimeout(); 299using var linkedCts = RemoteJSDataStream.ValueLinkedCancellationTokenSource.Create(token1, token2); 312using var linkedCts = RemoteJSDataStream.ValueLinkedCancellationTokenSource.Create( 328using var linkedCts = RemoteJSDataStream.ValueLinkedCancellationTokenSource.Create(cts1.Token, cts2.Token); 345private static async Task<RemoteJSDataStream> CreateRemoteJSDataStreamAsync(TestRemoteJSRuntime jsRuntime = null) 348var remoteJSDataStream = await RemoteJSDataStream.CreateRemoteJSDataStreamAsync(jsRuntime ?? _jsRuntime, jsStreamReference, totalLength: 100, signalRMaximumIncomingBytes: 10_000, jsInteropDefaultCallTimeout: TimeSpan.FromMinutes(1), cancellationToken: CancellationToken.None); 352private static long GetStreamId(RemoteJSDataStream stream, RemoteJSRuntime runtime) =>