Add tests for stream_builder.0.dart API example. (#147832)

This PR contributes to https://github.com/flutter/flutter/issues/130459

### Description
- Updates `examples/api/lib/widgets/async/stream_builder.0.dart`
- Adds test for `examples/api/lib/widgets/async/stream_builder.0.dart`
This commit is contained in:
Kostia Sokolovskyi 2024-05-10 23:48:35 +02:00 committed by GitHub
parent 1128eabec6
commit 456d176a70
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 245 additions and 94 deletions

View File

@ -405,7 +405,6 @@ final Set<String> _knownMissingTests = <String>{
'examples/api/test/widgets/nested_scroll_view/nested_scroll_view.0_test.dart',
'examples/api/test/widgets/scroll_position/scroll_metrics_notification.0_test.dart',
'examples/api/test/widgets/media_query/media_query_data.system_gesture_insets.0_test.dart',
'examples/api/test/widgets/async/stream_builder.0_test.dart',
'examples/api/test/widgets/async/future_builder.0_test.dart',
'examples/api/test/widgets/restoration_properties/restorable_value.0_test.dart',
'examples/api/test/widgets/animated_size/animated_size.0_test.dart',

View File

@ -13,34 +13,54 @@ void main() => runApp(const StreamBuilderExampleApp());
class StreamBuilderExampleApp extends StatelessWidget {
const StreamBuilderExampleApp({super.key});
static const Duration delay = Duration(seconds: 1);
@override
Widget build(BuildContext context) {
return const MaterialApp(
home: StreamBuilderExample(),
home: StreamBuilderExample(delay: delay),
);
}
}
class StreamBuilderExample extends StatefulWidget {
const StreamBuilderExample({super.key});
const StreamBuilderExample({
required this.delay,
super.key,
});
final Duration delay;
@override
State<StreamBuilderExample> createState() => _StreamBuilderExampleState();
}
class _StreamBuilderExampleState extends State<StreamBuilderExample> {
final Stream<int> _bids = (() {
late final StreamController<int> controller;
controller = StreamController<int>(
onListen: () async {
await Future<void>.delayed(const Duration(seconds: 1));
controller.add(1);
await Future<void>.delayed(const Duration(seconds: 1));
await controller.close();
},
);
return controller.stream;
})();
late final StreamController<int> _controller = StreamController<int>(
onListen: () async {
await Future<void>.delayed(widget.delay);
if (!_controller.isClosed) {
_controller.add(1);
}
await Future<void>.delayed(widget.delay);
if (!_controller.isClosed) {
_controller.close();
}
},
);
Stream<int> get _bids => _controller.stream;
@override
void dispose() {
if (!_controller.isClosed) {
_controller.close();
}
super.dispose();
}
@override
Widget build(BuildContext context) {
@ -50,86 +70,108 @@ class _StreamBuilderExampleState extends State<StreamBuilderExample> {
child: Container(
alignment: FractionalOffset.center,
color: Colors.white,
child: StreamBuilder<int>(
stream: _bids,
builder: (BuildContext context, AsyncSnapshot<int> snapshot) {
List<Widget> children;
if (snapshot.hasError) {
children = <Widget>[
const Icon(
Icons.error_outline,
color: Colors.red,
size: 60,
),
Padding(
padding: const EdgeInsets.only(top: 16),
child: Text('Error: ${snapshot.error}'),
),
Padding(
padding: const EdgeInsets.only(top: 8),
child: Text('Stack trace: ${snapshot.stackTrace}'),
),
];
} else {
switch (snapshot.connectionState) {
case ConnectionState.none:
children = const <Widget>[
Icon(
Icons.info,
color: Colors.blue,
size: 60,
),
Padding(
padding: EdgeInsets.only(top: 16),
child: Text('Select a lot'),
),
];
case ConnectionState.waiting:
children = const <Widget>[
SizedBox(
width: 60,
height: 60,
child: CircularProgressIndicator(),
),
Padding(
padding: EdgeInsets.only(top: 16),
child: Text('Awaiting bids...'),
),
];
case ConnectionState.active:
children = <Widget>[
const Icon(
Icons.check_circle_outline,
color: Colors.green,
size: 60,
),
Padding(
padding: const EdgeInsets.only(top: 16),
child: Text('\$${snapshot.data}'),
),
];
case ConnectionState.done:
children = <Widget>[
const Icon(
Icons.info,
color: Colors.blue,
size: 60,
),
Padding(
padding: const EdgeInsets.only(top: 16),
child: Text('\$${snapshot.data} (closed)'),
),
];
}
}
return Column(
mainAxisAlignment: MainAxisAlignment.center,
children: children,
);
},
),
child: BidsStatus(bids: _bids),
),
);
}
}
class BidsStatus extends StatelessWidget {
const BidsStatus({
required this.bids,
super.key,
});
final Stream<int>? bids;
@override
Widget build(BuildContext context) {
return StreamBuilder<int>(
stream: bids,
builder: (BuildContext context, AsyncSnapshot<int> snapshot) {
List<Widget> children;
if (snapshot.hasError) {
children = <Widget>[
const Icon(
Icons.error_outline,
color: Colors.red,
size: 60,
),
Padding(
padding: const EdgeInsets.only(top: 16),
child: Text('Error: ${snapshot.error}'),
),
Padding(
padding: const EdgeInsets.only(top: 8),
child: Text(
'Stack trace: ${snapshot.stackTrace}',
maxLines: 1,
overflow: TextOverflow.ellipsis,
),
),
];
} else {
switch (snapshot.connectionState) {
case ConnectionState.none:
children = const <Widget>[
Icon(
Icons.info,
color: Colors.blue,
size: 60,
),
Padding(
padding: EdgeInsets.only(top: 16),
child: Text('Select a lot'),
),
];
case ConnectionState.waiting:
children = const <Widget>[
SizedBox(
width: 60,
height: 60,
child: CircularProgressIndicator(),
),
Padding(
padding: EdgeInsets.only(top: 16),
child: Text('Awaiting bids...'),
),
];
case ConnectionState.active:
children = <Widget>[
const Icon(
Icons.check_circle_outline,
color: Colors.green,
size: 60,
),
Padding(
padding: const EdgeInsets.only(top: 16),
child: Text('\$${snapshot.data}'),
),
];
case ConnectionState.done:
children = <Widget>[
const Icon(
Icons.info,
color: Colors.blue,
size: 60,
),
Padding(
padding: const EdgeInsets.only(top: 16),
child: Text(
snapshot.hasData
? '\$${snapshot.data} (closed)'
: '(closed)',
),
),
];
}
}
return Column(
mainAxisAlignment: MainAxisAlignment.center,
children: children,
);
},
);
}
}

View File

@ -0,0 +1,110 @@
// Copyright 2014 The Flutter Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
import 'dart:async';
import 'package:flutter/material.dart';
import 'package:flutter_api_samples/widgets/async/stream_builder.0.dart'
as example;
import 'package:flutter_test/flutter_test.dart';
void main() {
testWidgets('StreamBuilder listens to internal stream', (WidgetTester tester) async {
await tester.pumpWidget(
const example.StreamBuilderExampleApp(),
);
expect(find.byType(CircularProgressIndicator), findsOneWidget);
expect(find.text('Awaiting bids...'), findsOneWidget);
await tester.pump(example.StreamBuilderExampleApp.delay);
expect(find.byIcon(Icons.check_circle_outline), findsOneWidget);
expect(find.text(r'$1'), findsOneWidget);
await tester.pump(example.StreamBuilderExampleApp.delay);
expect(find.byIcon(Icons.info), findsOneWidget);
expect(find.text(r'$1 (closed)'), findsOneWidget);
});
testWidgets('BidsStatus correctly displays error state', (WidgetTester tester) async {
final StreamController<int> controller = StreamController<int>();
addTearDown(controller.close);
controller.onListen = () {
controller.addError('Unexpected error!', StackTrace.empty);
};
await tester.pumpWidget(
MaterialApp(
home: example.BidsStatus(bids: controller.stream),
),
);
await tester.pump();
expect(find.byIcon(Icons.error_outline), findsOneWidget);
expect(find.text('Error: Unexpected error!'), findsOneWidget);
expect(find.text('Stack trace: ${StackTrace.empty}'), findsOneWidget);
});
testWidgets('BidsStatus correctly displays none state', (WidgetTester tester) async {
await tester.pumpWidget(
const MaterialApp(
home: example.BidsStatus(bids: null),
),
);
expect(find.byIcon(Icons.info), findsOneWidget);
expect(find.text('Select a lot'), findsOneWidget);
});
testWidgets('BidsStatus correctly displays waiting state', (WidgetTester tester) async {
final StreamController<int> controller = StreamController<int>();
addTearDown(controller.close);
await tester.pumpWidget(
MaterialApp(
home: example.BidsStatus(bids: controller.stream),
),
);
expect(find.byType(CircularProgressIndicator), findsOneWidget);
expect(find.text('Awaiting bids...'), findsOneWidget);
});
testWidgets('BidsStatus correctly displays active state', (WidgetTester tester) async {
final StreamController<int> controller = StreamController<int>();
addTearDown(controller.close);
controller.onListen = () {
controller.add(1);
};
await tester.pumpWidget(
MaterialApp(
home: example.BidsStatus(bids: controller.stream),
),
);
await tester.pump();
expect(find.byIcon(Icons.check_circle_outline), findsOneWidget);
expect(find.text(r'$1'), findsOneWidget);
});
testWidgets('BidsStatus correctly displays done state', (WidgetTester tester) async {
final StreamController<int> controller = StreamController<int>();
controller.close();
await tester.pumpWidget(
MaterialApp(
home: example.BidsStatus(bids: controller.stream),
),
);
await tester.pump();
expect(find.byIcon(Icons.info), findsOneWidget);
expect(find.text('(closed)'), findsOneWidget);
});
}