AmityMessage stream never closes

[szymon-zawadzki-netbulls]

messageLiveCollection = MessageLiveCollection(
 request: () => AmityChatClient.newMessageRepository()
   .getMessages(channelId)
   .build(),
);

messageLiveSubscription = messageLiveCollection
 ?.getStreamController()
   .stream
   .listen(_onNewMessages);

...

messageLiveSubscription?.cancel();

Despite closing the subscription to the message stream. Underhood the stream is not closed.

You can observe that the stream inside MessageObserveUsecase::listen is never closed. Every opening new MessageLiveCollection stream causes a new stream in MessageObserveUsecase::listen. This is a serious bug that causes memory leaks.