Блог

Я создал этот код, и я хочу, чтобы при нажатии на кнопку происходило то, что я хочу, чтобы диаграмма элементов повторно отображалась с новыми значениями (которые должны быть старыми значениями, но ценность еды увеличилась на 1). Я использую диаграмму элементов из пакета pie_chart: 0.8.0. Deposit — это не что иное, как pojo (категория строки и вклад int).bloc.dart содержит глобальный экземпляр блока, средство получения потока и инициализацию потока типа Вот мой код:

 import 'package:flutter/material.dart';
import 'package:pie_chart/pie_chart.dart';
import 'bloc.dart';
import 'Deposit.dart';

void main() => runApp(MyApp());

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'bloc Chart',
      theme: ThemeData(
        primarySwatch: Colors.blueGrey,
      ),
      home: HomePage(),
    );
  }
}

class HomePage extends StatelessWidget {
  Map<String, double> datamap = new Map();

  @override
  Widget build(BuildContext context) {
    datamap.putIfAbsent("Food", () => 5);
    datamap.putIfAbsent("transportation", () => 3);
    return Scaffold(
      appBar: AppBar(
        title: Text("PieChart using blocs"),
      ),
      body: Column(
        children: <Widget>[
          StreamBuilder<Deposit>(
              stream: bloc.data, //A stream of Deposit data
              builder: (context, snapshot) {
                addDeposit(Deposit("Food", 1), datamap);
                debugPrint("Value of food in map is: ${datamap["Food"]}");
                return PieChart(dataMap: datamap);
              }),
          SizedBox.fromSize(
            size: Size(20, 10),
          ),
          RaisedButton(
            onPressed: () {
              bloc.add(Deposit("Food", 1)); //returns the stream.add
            },
            child: Icon(Icons.add),
          ),
        ],
      ),
    );
  }

  void addDeposit(Deposit dep, Map<String, double> map) {
    if (map.containsKey(dep.category)) {
      map.update(dep.category, (value) => value   dep.price);
    } else
      map.putIfAbsent(dep.category, () => dep.price);
  }
}
  

Я думаю, ваша проблема в том, что поток не запускает новые события. Вам не нужно закрывать поток для восстановления. Я не вижу нигде в вашем коде, где вы запускаете новые события для потока. Проверьте приведенный ниже код, чтобы увидеть простой способ, как вы можете обновить a StatelessWidget с помощью StreamBuilder .

 class CustomWidgetWithStream extends StatelessWidget {
  final CustomBlock block = CustomBlock();

  @override
  Widget build(BuildContext context) {
    return Column(
      children: <Widget>[
        StreamBuilder(
            stream: block.stream,
            builder: (context, stream) {
              return Text("${stream.data.toString()}");
            }),
        RaisedButton(
          onPressed: () {
            block.incrementNumber();
          },
          child: Text("Increment"),
        )
      ],
    );
  }
}

class CustomBlock {
  num counter = 10;
  final StreamController<num> _controller = StreamController();

  Stream<num> get stream => _controller.stream;

  CustomBlock() {
    _controller.onListen = () {
      _controller.add(counter); // triggered when the first subscriber is added
    };
  }

  void incrementNumber() {
    counter  = 1;
    _controller.add(counter); // ADD NEW EVENT TO THE STREAM
  }

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

Хотя это рабочий фрагмент кода, я бы настоятельно рекомендовал изменить ваш виджет с StatelessWidget на StatefulWidget по двум причинам:
* если вы идете «по инструкции», если виджет изменяет содержимое сам по себе, то это не StatelessWidget , виджет без состояния отображает только данные, которые ему предоставлены. В вашем случае виджет обрабатывает нажатие, а затем решает, что делать дальше и как обновить себя.
* если вы используете потоки, в виджете с отслеживанием состояния вы можете безопасно закрыть поток, как вы можете видеть в приведенном выше коде, безопасного способа закрыть поток не существует. Если вы не закроете поток, может возникнуть нежелательное поведение или даже сбой.

Это мой файл блока

 import 'package:rxdart/rxdart.dart';
import 'package:testing/Deposit.dart';

class Bloc{

  final _data = new BehaviorSubject<Deposit>();

  Stream<Deposit> get data => _data.stream;

  Function(Deposit) get add => _data.sink.add;

  void dispose(){
    _data.close();
  }

}

Bloc bloc = new Bloc();