我有一个消息列表。每条消息都有一个唯一的 GUID。
我的设置适用于正常使用:用户单击对话,列表打开,其中包含属于该对话的所有消息,按最近的顺序排列。
对话片段
@Override
public void onViewCreated(
@NonNull View view,
@Nullable Bundle savedInstanceState
) {
LifecycleOwner lifecycleOwner = getViewLifecycleOwner();
viewModel = new ViewModelProvider(this).get(ConversationViewModel.class);
viewModel
.getMessageList(lifecycleOwner, conversationId) // conversationId is a global variable
.observe(lifecycleOwner, messagePagingData -> adapter.submitData(
lifecycleOwner.getLifecycle(),
messagePagingData
));
super.onViewCreated(view, savedInstanceState);
}
会话视图模型
final PagingConfig pagingConfig = new PagingConfig(10, 10, false, 20);
private final ConversationRepository conversationRepository;
public ConversationViewModel(@NonNull Application application) {
super(application);
conversationRepository = new ConversationRepository(application);
}
public LiveData<PagingData<ItemMessage>> getMessageList(
@NonNull LifecycleOwner lifecycleOwner,
@NonNull String conversationId
) {
return PagingLiveData.cachedIn(
PagingLiveData.getLiveData(new Pager<>(pagingConfig, () -> conversationRepository.getMessageList(conversationId))),
lifecycleOwner.getLifecycle()
);
}
会话存储库
private final MessageDao messageDao;
public ConversationRepository(@NonNull Context context) {
AppDatabase database = AppDatabase.getDatabase(context);
messageDao = database.messageDao();
}
public PagingSource<Integer, ItemMessage> getMessageList(@NonNull String conversationId) {
return messageDao.getMessageList(conversationId);
}
消息道
@Query(
"SELECT * FROM Message " +
"WHERE Message.conversationId = :conversationId " +
"ORDER BY Message.time DESC"
)
public abstract PagingSource<Integer, ItemMessage> getMessageList(String conversationId);
现在我的目标是能够打开已经在特定消息处滚动的对话。
我也不想加载整个对话然后滚动到消息,有些对话可能会很长,我不想让用户自动滚动可能需要很长时间才能到达特定消息。
理想情况下,我设想的正确方式是将消息 id 传递到视图中,在该消息 id 之前和之后加载一大块 X 消息,然后在它已经呈现给用户之后,RecyclerView
它将加载更多如果用户上升或下降。
这并不意味着使用网络请求,整个会话已经在数据库中可用,因此它只会使用数据库中已经存在的信息。
我已经尝试理解使用ItemKeyedDataSource
or的示例PageKeyedDataSource
,但我无处可去,因为每次这些示例都仅在 Kotlin 中,并且需要 Retrofit 才能工作,而我不使用。因为这些示例对于像我这样使用 Java 且不使用 Retrofit 的人来说完全没用。
如何做到这一点?
请用 Java 提供答案,而不仅仅是 Kotlin(只要它也在 Java 中,kotlin 就可以)并且请不要建议新的库。