50 references to ReadUntilAsync
Aspire.Dashboard.Tests (50)
Terminal\TerminalWebSocketTests.cs (50)
26await ReadUntilAsync(browser, _ => true, timeout.Token); 28await ReadUntilAsync(browser, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 33await ReadUntilAsync(browser, frame => frame.GetProperty("history").GetProperty("totalRows").GetInt32() >= 36, timeout.Token); 41var resized = await ReadUntilAsync(browser, frame => frame.GetProperty("columns").GetInt32() == width && 52await ReadUntilAsync(browser, frame => frame.GetProperty("columns").GetInt32() == 20, timeout.Token); 55await ReadUntilAsync(reconnected, _ => true, timeout.Token); 69var initial = await ReadUntilAsync(first, frame => frame.GetProperty("peer").GetProperty("id").ValueKind == JsonValueKind.String, timeout.Token); 76var primary = await ReadUntilAsync(first, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 82var viewer = await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("id").ValueKind == JsonValueKind.String, timeout.Token); 87await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("primaryId").ValueKind == JsonValueKind.Null, timeout.Token); 89var takeover = await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 103await ReadUntilAsync(browser, _ => true, timeout.Token); 134await ReadUntilAsync(browser, _ => true, timeout.Token); 166await ReadUntilAsync(browser, _ => true, timeout.Token); 169var graphics = await ReadUntilAsync(browser, frame => frame.GetProperty("placements").GetArrayLength() > 0, timeout.Token); 175var restored = await ReadUntilAsync(reconnected, frame => frame.GetProperty("placements").GetArrayLength() > 0, timeout.Token); 192await ReadUntilAsync(first, _ => true, timeout.Token); 207var initial = await ReadUntilAsync(first, HasPlacement, timeout.Token); 211var late = await ReadUntilAsync(second, HasPlacement, timeout.Token); 220ReadUntilAsync(first, HasMovedPlacement, timeout.Token), 221ReadUntilAsync(second, HasMovedPlacement, timeout.Token)); 227var restored = await ReadUntilAsync(reconnected, HasMovedPlacement, timeout.Token); 254await ReadUntilAsync(first, _ => true, timeout.Token); 258var initial = await ReadUntilAsync(first, frame => frame.GetProperty("placements").GetArrayLength() == 1, timeout.Token); 270var original = await ReadUntilAsync(first, frame => frame.GetProperty("placements").GetArrayLength() == 1 && 272var restored = await ReadUntilAsync(late, frame => frame.GetProperty("placements").GetArrayLength() == 1, timeout.Token); 292await ReadUntilAsync(first, _ => true, timeout.Token); 295var initial = await ReadUntilAsync(first, frame => frame.GetProperty("placements").GetArrayLength() == 1, timeout.Token); 309ReadUntilAsync(first, HasMovedPlacement, timeout.Token), 310ReadUntilAsync(late, HasMovedPlacement, timeout.Token)); 328await ReadUntilAsync(browser, _ => true, timeout.Token); 334var initial = await ReadUntilAsync(browser, frame => frame.GetProperty("hyperlinks").GetArrayLength() > 0, timeout.Token); 338var changed = await ReadUntilAsync(browser, frame => frame.GetProperty("hyperlinks").EnumerateArray() 344var restored = await ReadUntilAsync(reconnected, frame => frame.GetProperty("hyperlinks").GetArrayLength() > 0, timeout.Token); 382await ReadUntilAsync(first, _ => true, timeout.Token); 392await ReadUntilAsync(second, frame => frame.GetProperty("peer").GetProperty("id").ValueKind == JsonValueKind.String, timeout.Token); 420await ReadUntilAsync(browser, _ => true, timeout.Token); 435var readOnly = await ReadUntilAsync(browser, frame => frame.GetProperty("full").GetBoolean(), timeout.Token); 442var primary = await ReadUntilAsync(browser, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 472await ReadUntilAsync(readOnly, _ => true, timeout.Token); 474await ReadUntilAsync(interactive, _ => true, timeout.Token); 477var primary = await ReadUntilAsync(interactive, frame => frame.GetProperty("peer").GetProperty("isPrimary").GetBoolean(), timeout.Token); 479await ReadUntilAsync(readOnly, frame => frame.GetProperty("peer").GetProperty("primaryId").GetString() == peerId, timeout.Token); 483var unchanged = await ReadUntilAsync(readOnly, frame => frame.GetProperty("full").GetBoolean(), timeout.Token); 520await ReadUntilAsync(browser, _ => true, timeout.Token); 623await ReadUntilAsync(browser, _ => true, timeout.Token); 683var frame = await ReadUntilAsync(socket, 698var selection = await ReadUntilAsync(socket, 703await ReadUntilAsync(socket, 707await ReadUntilAsync(socket,