Base class, BLoC provider and rxdart
builder for BLoC pattern in Flutter.
dependencies:
flutter_bloc_pattern: <latest_version>
import 'package:flutter_bloc_pattern/flutter_bloc_pattern.dart';
class MyBloc implements BaseBloc {
Stream<String> get stream;
@override
void dispose() {}
}
final bloc = BlocProvider.of<MyBloc>(context);
return RxStreamBuilder(
stream: bloc.stream,
builder: (context, data) {
return ...;
},
);
import 'dart:async';
import 'package:flutter_bloc_pattern/flutter_bloc_pattern.dart';
import 'package:rxdart_ext/rxdart_ext.dart';
class CounterBloc extends DisposeCallbackBaseBloc {
/// Inputs
final VoidAction increment;
/// Outputs
final StateStream<int> state;
CounterBloc._({
required void Function() dispose,
required this.increment,
required this.state,
}) : super(dispose);
factory CounterBloc() {
// ignore: close_sinks
final incrementController = StreamController<void>();
final state = incrementController.stream
.scan<int>((acc, _, __) => acc + 1, 0)
.publishState(0);
final connection = state.connect();
return CounterBloc._(
dispose: () async {
await connection.cancel();
await incrementController.close();
print('CounterBloc::disposed');
},
increment: () => incrementController.add(null),
state: state,
);
}
}
import 'package:example/bloc.dart';
import 'package:flutter/material.dart';
import 'package:flutter_bloc_pattern/flutter_bloc_pattern.dart';
class TextCounter1 extends StatelessWidget {
const TextCounter1({Key? key}) : super(key: key);
@override
Widget build(BuildContext context) {
final bloc = BlocProvider.of<CounterBloc>(context);
return RxStreamBuilder<int>(
stream: bloc.state,
builder: (context, state) {
return Text(
'COUNTER 1: $state',
style: Theme.of(context).textTheme.headline6,
);
},
);
}
}
class IncrementButton extends StatelessWidget {
const IncrementButton({Key? key}) : super(key: key);
@override
Widget build(BuildContext context) {
final bloc = context.bloc<CounterBloc>();
return FloatingActionButton(
onPressed: bloc.increment,
tooltip: 'Increment',
child: Icon(Icons.add),
);
}
}