import 'package:rxdart/rxdart.dart';
import 'package:weather_bloc/src/models/condition_model.dart';
import 'package:weather_bloc/src/resources/repository.dart';

class ConditionsBloc {
  final _repository = Repository();
  final _conditionsFetcher = PublishSubject<ConditionsModel>();

  Observable<ConditionsModel> get conditions => _conditionsFetcher.stream;

  fetchConditions() async {
    ConditionsModel weatherConditions = await _repository.fetchWeatherData();
    _conditionsFetcher.sink.add(weatherConditions);
  }

  dispose() {
    _conditionsFetcher.close();
  }
}

final blocConditions = ConditionsBloc();