listen property

StreamController<AmityComment> listen

Listen Update in Amity Comment

Implementation

StreamController<AmityComment> get listen {
  StreamController<AmityComment> controller = StreamController<AmityComment>();

  serviceLocator<CommentDbAdapter>().listenCommentEntity(commentId!).listen((event) {
    final updateAmityComment = event.convertToAmityComment();

    //TOOD: Good idea would be have compose method inside the object itself
    serviceLocator<CommentComposerUsecase>().get(updateAmityComment).then(
          (value) => controller.add(value),
        );
  });

  return controller;
}