import 'dart:async';

void main() {
  final data = {'イチゴ': '苺', 'イチジク': '無花果'};

  //Sink
  final controller = StreamController<String>();
  //Stream
  //rxdartというライブラリをimportして、
  //BehaviorSubjectを用いることが多いです。
  final kanjiStream = StreamController<String>();

  transformToKanjiFrom(String katakana) {
    if (data.containsKey(katakana)) {
      kanjiStream.add(data[katakana]);
      return;
    }
    print('${katakana}の漢字は不明です');
  }

	//FlutterではView部分に相当します。
  //StreamBuilderなどのStreamを監視するWidgetを使います。
  kanjiStream.stream.listen((kanji) {
    print(kanji);
  });

  controller.stream.listen(transformToKanjiFrom);

  controller.sink.add('イチゴ');
  controller.sink.add('ドラゴンフルーツ');
  controller.sink.add('イチジク');
}