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,