Searched refs:numberOfMessages (Results 1 – 5 of 5) sorted by relevance
165 public void processMessagesFromDatabase(int numberOfMessages) { in processMessagesFromDatabase() argument168 numberOfMessages, KAnonMessageConstants.MessageStatus.NOT_PROCESSED); in processMessagesFromDatabase()
83 int numberOfMessages, @KAnonMessageConstants.MessageStatus int status) { in fetchNKAnonMessagesWithStatus() argument84 return mKAnonMessageDao.getNLatestKAnonMessagesWithStatus(numberOfMessages, status).stream() in fetchNKAnonMessagesWithStatus()
270 public void onConversationMessagesUpdated(final int numberOfMessages) { in onConversationMessagesUpdated() argument
130 void onConversationMessagesUpdated(int numberOfMessages); in onConversationMessagesUpdated() argument
2526 final int numberOfMessages = 30; in testSendMessageQueueSequence() local2579 int remainingMessages = numberOfMessages; in testSendMessageQueueSequence()2580 for (int i = 0; i < numberOfMessages; ++i) { in testSendMessageQueueSequence()2597 inOrder.verify(mockSessionCallback, times(numberOfMessages)).onMessageSendSuccess( in testSendMessageQueueSequence()2599 for (int i = 0; i < numberOfMessages; ++i) { in testSendMessageQueueSequence()2633 final int numberOfMessages = 70; in testSendMessageQueueLimitBlock() local2636 final int numOfReject = numberOfMessages - messageQueueDepthPerUid; in testSendMessageQueueLimitBlock()2719 for (int i = 0; i < numberOfMessages; ++i) { in testSendMessageQueueLimitBlock()2723 for (int i = 0; i < numberOfMessages; ++i) { in testSendMessageQueueLimitBlock()2734 for (int i = 0; i < numberOfMessages * 2; ++i) { in testSendMessageQueueLimitBlock()[all …]