ProgressBloc constructor

ProgressBloc(
  1. ProgressState initialState
)

Create a new instance and bind listeners.

Implementation

ProgressBloc(super.initialState) {
  on<MessageRead>((event, emit) {
    emit(state.copyWith(messagesTotal: state.messagesTotal + event.count));
  });
  on<MessageProcessed>((event, emit) {
    emit(state.copyWith(
        messagesProcessed: state.messagesProcessed + event.count));
  });
  on<ConversationRead>((event, emit) {
    emit(state.copyWith(
        conversationsTotal: state.conversationsTotal + event.count));
  });
  on<ConversationProcessed>((event, emit) {
    emit(state.copyWith(
        conversationsProcessed: state.conversationsProcessed + event.count));
  });
  on<BuildComplete>((event, emit) => emit(state.copyWith(complete: true)));
  on<PassComplete>((event, emit) => emit(state.copyWith(
      passesComplete: state.passesComplete + 1,
      conversationsProcessed: event.resetCounts ? 0 : null,
      conversationsTotal: event.resetCounts ? 0 : null,
      conversationsDropped: event.resetCounts ? 0 : null,
      messagesProcessed: event.resetCounts ? 0 : null,
      messagesTotal: event.resetCounts ? 0 : null,
      messagesDropped: event.resetCounts ? 0 : null)));
}