re-flow test/ipc/server_streaming_test.dart per dart format
test / unit + widget + golden + a11y (push) Failing after 27s
test / integration_test (xvfb) (push) Has been skipped
test / bundle smoke (xvfb 5s) (push) Has been skipped
test / daemon subprocess + web WASM smoke (push) Has been skipped
test / dart doc (lib API) (push) Failing after 28s
test / unit + widget + golden + a11y (push) Failing after 27s
test / integration_test (xvfb) (push) Has been skipped
test / bundle smoke (xvfb 5s) (push) Has been skipped
test / daemon subprocess + web WASM smoke (push) Has been skipped
test / dart doc (lib API) (push) Failing after 28s
Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
@@ -212,9 +212,11 @@ void main() {
|
||||
addTearDown(s.close);
|
||||
final r = _lineReader(s);
|
||||
final q = _Lines(r.lines);
|
||||
await _send(s, IpcRequest(id: 'a', cmd: '_argv', args: {
|
||||
'argv': ['tail', '--events', '--filter', 'pane'],
|
||||
}));
|
||||
await _send(
|
||||
s,
|
||||
IpcRequest(id: 'a', cmd: '_argv', args: {
|
||||
'argv': ['tail', '--events', '--filter', 'pane'],
|
||||
}));
|
||||
final ack = IpcMessage.decode(await q.next()) as IpcResponse;
|
||||
expect(ack.ok, isTrue);
|
||||
expect(ack.data['streaming'], isTrue);
|
||||
|
||||
Reference in New Issue
Block a user