message receiving observer
static Stream<List<NIMMessage>> observeReceiveMessage() { return NimCore.instance.messageService.onMessage; }