listen property

StreamController<AmityPost> listen

Listen Post Id

Implementation

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

  serviceLocator<PostDbAdapter>().listenPostEntity(postId!).listen((event) {
    final updateAmityPost = event.convertToAmityPost();

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

  return controller;
}