eventos_bloc.dart

import 'dart:async';
import 'package:bloc_pattern/bloc_pattern.dart';
import 'package:rxdart/rxdart.dart';
import 'package:minhacidade/blocs/cidade_bloc.dart';
import 'package:minhacidade/domain/evento_domain.dart';

class EventoBloc extends BlocBase {
  final _controller = BehaviorSubject<List<Evento>>();
  get stream => _controller.stream;

  getEventos() async {
    try {
      var _cidade = await CidadeBloc.getCidadeEscolhida();
      if (_cidade.id != null){
        List<Evento> _eventos = await Evento.getEventos(_cidade.id);
        if (_eventos.length > 0){
          _controller.sink.add(_eventos);
        }
      }
    } catch (error) {
      print("Erro getEvents");
    }
  }

  getUpdate() async {
    try {
      var _cidade = await CidadeBloc.getCidadeEscolhida();
      if(_cidade.id != null){
        var _eventos = await Evento.getEventos(_cidade.id);
        _controller.sink.add(_eventos);
      }
    } catch (error) {
      print("Erro getEvents");
    }
  }

  close() => _controller.close();
}