我的Bloc里有几条流。我不知道这是否是一个正确的方法,因为我是Flutter和Bloc模式的新手。但我如何能把Bloc中的流合并成一个?
欢迎任何关于这个主题的提示......
我的Bloc文件
import 'package:flutter/material.dart';
import 'package:rxdart/rxdart.dart';
class WelcomeBloc {
final _controller = PublishSubject<PageController>();
final _page = PublishSubject<int>();
final _lastPage = PublishSubject<bool>();
Stream<dynamic> get combinedStream =>
CombineLatestStream.list([getController, currentPage, isLastPage]);
Stream<PageController> get getController => _controller.stream;
Stream<int> get currentPage => _page.stream;
Stream<bool> get isLastPage => _lastPage.stream;
updatePage(int page) {
_page.sink.add(page);
}
updatePageState(bool state) {
_lastPage.sink.add(state);
}
dispose() {
_controller.close();
_page.close();
_lastPage.close();
}
}
final welcomeBloc = WelcomeBloc();
消费者
import 'package:flutter/material.dart';
import '../../blocs/welcome_bloc.dart';
import './pages/page.dart';
import './pages/page2.dart';
import './pages/login.dart';
class ViewerWrapper extends StatelessWidget {
@override
Widget build(BuildContext context) {
return StreamBuilder(
stream: welcomeBloc.combinedStream,
builder: (context, AsyncSnapshot snapshot) {
return PageView(
children: <Widget>[
Page1(),
Page2(),
Login(),
],
onPageChanged: (page) {
welcomeBloc.updatePage(page);
print(snapshot.data._page);
// welcomeBloc.updatePage(page + 1);
},
// controller: snapshot.data.getController,
);
});
}
}
你可以使用 Rx.combineLatest3
喜欢 这个环节合并流,但我从你的代码中了解到,最好是定义一个像这样的模型。
Class MyModel{
PageController pageController;
int currentPage;
bool isLastPage;
...
}
然后有一个单一的流,与它一起工作。
我用两种方法修改了代码。
第一种
你可以定义一个模型,然后用这个模型工作,所以你不需要3个不同的流,如果你总是需要合并的流版本,而不是其他地方的每一个流,这个是可以的。
我在一个文件中写了代码。
import 'package:flutter/material.dart';
import 'package:rxdart/rxdart.dart';
class MyModel {
PageController pageController;
int currentPage;
bool isLastPage;
MyModel({this.currentPage, this.pageController, this.isLastPage});
}
class WelcomeBloc {
var _myModel = PublishSubject<MyModel>();
Stream<MyModel> get getModel => _myModel.stream;
// updatePage(int page) {
// _page.sink.add(page);
// }
// updatePageState(bool state) {
// _lastPage.sink.add(state);
// }
void updateModel(MyModel model) {
_myModel.sink.add(model);
}
dispose() {
_myModel.close();
}
}
final welcomeBloc = WelcomeBloc();
class ViewerWrapper extends StatelessWidget {
@override
Widget build(BuildContext context) {
return StreamBuilder<MyModel>(
stream: welcomeBloc.getModel,
builder: (context, AsyncSnapshot<MyModel> snapshot) {
if (snapshot.hasData) {
MyModel model = snapshot.data;
return PageView(
children: <Widget>[
Page1(),
Page2(),
Login(),
],
onPageChanged: (page) {
model.currentPage = page;
welcomeBloc.updateModel(model);
print(model.currentPage);
// welcomeBloc.updatePage(page + 1);
},
controller: model.pageController,
);
}
return Center(child: CircularProgressIndicator());
});
}
}
第二个
如果你还需要其他地方的流等等,你可以组合流,你可以用任何你想要的方式来组合,列表,地图,或者一个定义的模型,我用了一个模型(MyModel)。
import 'package:flutter/material.dart';
import 'package:rxdart/rxdart.dart';
class MyModel {
PageController pageController;
int currentPage;
bool isLastPage;
MyModel({this.currentPage, this.pageController, this.isLastPage});
}
class WelcomeBloc {
final _controller = PublishSubject<PageController>();
final _page = PublishSubject<int>();
final _lastPage = PublishSubject<bool>();
Stream<MyModel> get combinedStream =>
Rx.combineLatest3(_page, _lastPage, _controller,
(int page, bool isLast, PageController controller) {
return MyModel(
currentPage: page,
isLastPage: isLast,
pageController: controller,
);
});
Stream<PageController> get getController => _controller.stream;
Stream<int> get currentPage => _page.stream;
Stream<bool> get isLastPage => _lastPage.stream;
updatePage(int page) {
_page.sink.add(page);
}
updatePageState(bool state) {
_lastPage.sink.add(state);
}
dispose() {
_controller.close();
_page.close();
_lastPage.close();
}
}
final welcomeBloc = WelcomeBloc();
class ViewerWrapper extends StatelessWidget {
@override
Widget build(BuildContext context) {
return StreamBuilder<MyModel>(
stream: welcomeBloc.combinedStream,
builder: (context, AsyncSnapshot<MyModel> snapshot) {
if (snapshot.hasData) {
MyModel model = snapshot.data;
return PageView(
children: <Widget>[
Page1(),
Page2(),
Login(),
],
onPageChanged: (page) {
welcomeBloc.updatePage(page);
print(model.currentPage);
// welcomeBloc.updatePage(page + 1);
},
controller: model.pageController,
);
}
return Center(child: CircularProgressIndicator());
});
}
}
不要以为是这样做的。虽然如果你想这样做,可以尝试把你的流构建器作为另一个流构建器的子程序。但我不推荐这种方式。
你不要听同一个集团的多个流,好的方法是每个集团架构一个流。
你可以多看看关于提供者的文章,他们比bloc简单,是flutter社区推荐的。