mirror of
https://github.com/vodemn/m3_lightmeter.git
synced 2024-10-19 14:50:40 +00:00
27 lines
1 KiB
Dart
27 lines
1 KiB
Dart
import 'dart:async';
|
|
import 'package:flutter/material.dart';
|
|
import 'package:flutter_bloc/flutter_bloc.dart';
|
|
import 'package:lightmeter/screens/metering/communication/bloc_communication_metering.dart';
|
|
import 'package:lightmeter/screens/metering/communication/state_communication_metering.dart'
|
|
as communication_states;
|
|
|
|
abstract class EvSourceBlocBase<E, S> extends Bloc<E, S> {
|
|
final MeteringCommunicationBloc communicationBloc;
|
|
late final StreamSubscription<communication_states.SourceState> _communicationSubscription;
|
|
|
|
EvSourceBlocBase(this.communicationBloc, super.initialState) {
|
|
_communicationSubscription = communicationBloc.stream
|
|
.where((event) => event is communication_states.SourceState)
|
|
.map((event) => event as communication_states.SourceState)
|
|
.listen(onCommunicationState);
|
|
}
|
|
|
|
@override
|
|
Future<void> close() async {
|
|
await _communicationSubscription.cancel();
|
|
return super.close();
|
|
}
|
|
|
|
@visibleForTesting
|
|
void onCommunicationState(communication_states.SourceState communicationState);
|
|
}
|