Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
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();
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.