54 references to ReadUntilAsync
Aspire.Dashboard.Tests (54)
Terminal\TerminalWebSocketTests.cs (54)
32var initial = await ReadUntilAsync(browser, _ => true, timeout.Token); 59var initial = await ReadUntilAsync(browser, frame => 72var detailsFrame = await ReadUntilAsync(browser, frame => 81var jumped = await ReadUntilAsync(browser, frame => 99await ReadUntilAsync(browser, _ => true, timeout.Token); 101await ReadUntilAsync(browser, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 106await ReadUntilAsync(browser, frame => frame.GetProperty("history").GetProperty("totalRows").GetInt32() >= 36, timeout.Token); 114var resized = await ReadUntilAsync(browser, frame => frame.GetProperty("columns").GetInt32() == width && 125await ReadUntilAsync(browser, frame => frame.GetProperty("columns").GetInt32() == 20, timeout.Token); 128await ReadUntilAsync(reconnected, _ => true, timeout.Token); 142var initial = await ReadUntilAsync(first, frame => frame.GetProperty("peer").GetProperty("id").ValueKind == JsonValueKind.String, timeout.Token); 149var primary = await ReadUntilAsync(first, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 155var viewer = await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("id").ValueKind == JsonValueKind.String, timeout.Token); 160await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("primaryId").ValueKind == JsonValueKind.Null, timeout.Token); 162var takeover = await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 176await ReadUntilAsync(browser, _ => true, timeout.Token); 207await ReadUntilAsync(browser, _ => true, timeout.Token); 239await ReadUntilAsync(browser, _ => true, timeout.Token); 242var graphics = await ReadUntilAsync(browser, frame => frame.GetProperty("placements").GetArrayLength() > 0, timeout.Token); 248var restored = await ReadUntilAsync(reconnected, frame => frame.GetProperty("placements").GetArrayLength() > 0, timeout.Token); 265await ReadUntilAsync(first, _ => true, timeout.Token); 280var initial = await ReadUntilAsync(first, HasPlacement, timeout.Token); 284var late = await ReadUntilAsync(second, HasPlacement, timeout.Token); 293ReadUntilAsync(first, HasMovedPlacement, timeout.Token), 294ReadUntilAsync(second, HasMovedPlacement, timeout.Token)); 300var restored = await ReadUntilAsync(reconnected, HasMovedPlacement, timeout.Token); 327await ReadUntilAsync(first, _ => true, timeout.Token); 331var initial = await ReadUntilAsync(first, frame => frame.GetProperty("placements").GetArrayLength() == 1, timeout.Token); 343var original = await ReadUntilAsync(first, frame => frame.GetProperty("placements").GetArrayLength() == 1 && 345var restored = await ReadUntilAsync(late, frame => frame.GetProperty("placements").GetArrayLength() == 1, timeout.Token); 365await ReadUntilAsync(first, _ => true, timeout.Token); 368var initial = await ReadUntilAsync(first, frame => frame.GetProperty("placements").GetArrayLength() == 1, timeout.Token); 382ReadUntilAsync(first, HasMovedPlacement, timeout.Token), 383ReadUntilAsync(late, HasMovedPlacement, timeout.Token)); 401await ReadUntilAsync(browser, _ => true, timeout.Token); 407var initial = await ReadUntilAsync(browser, frame => frame.GetProperty("hyperlinks").GetArrayLength() > 0, timeout.Token); 411var changed = await ReadUntilAsync(browser, frame => frame.GetProperty("hyperlinks").EnumerateArray() 417var restored = await ReadUntilAsync(reconnected, frame => frame.GetProperty("hyperlinks").GetArrayLength() > 0, timeout.Token); 455await ReadUntilAsync(first, _ => true, timeout.Token); 465await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("id").ValueKind == JsonValueKind.String, timeout.Token); 493await ReadUntilAsync(browser, _ => true, timeout.Token); 508var readOnly = await ReadUntilAsync(browser, frame => frame.GetProperty("full").GetBoolean(), timeout.Token); 515var primary = await ReadUntilAsync(browser, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 545await ReadUntilAsync(readOnly, _ => true, timeout.Token); 547await ReadUntilAsync(interactive, _ => true, timeout.Token); 550var primary = await ReadUntilAsync(interactive, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 552await ReadUntilAsync(readOnly, frame => frame.GetProperty("peer").GetProperty("primaryId").GetString() == peerId, timeout.Token); 556var unchanged = await ReadUntilAsync(readOnly, frame => frame.GetProperty("full").GetBoolean(), timeout.Token); 593await ReadUntilAsync(browser, _ => true, timeout.Token); 696await ReadUntilAsync(browser, _ => true, timeout.Token); 756var frame = await ReadUntilAsync(socket, 771var selection = await ReadUntilAsync(socket, 776await ReadUntilAsync(socket, 780await ReadUntilAsync(socket,