m3_lightmeter/lib/screens/metering/components/shared/ev_source_base/bloc_base_ev_source.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);
}