- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for curTop (0.05 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
internal const val CLOSE_NO_STATUS_CODE = 1005 fun toggleMask( cursor: Buffer.UnsafeCursor, key: ByteArray, ) { var keyIndex = 0 val keyLength = key.size do { val buffer = cursor.data var i = cursor.start val end = cursor.end if (buffer != null) { while (i < end) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/ResultSetUtil.java
throw new SQLRuntimeException(ex); } } /** * Moves the cursor to the specified position. * * @param resultSet * The result set. Must not be {@literal null}. * @param index * The position. * @return Whether the cursor successfully moved to the specified position. * @throws SQLRuntimeException
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 2.9K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
@Override public E next() { if (cursor >= array.length) throw new NoSuchElementException(); lastRet = cursor; // array comes from q.toArray() and so should have only E's in it @SuppressWarnings("unchecked") E e = (E) array[cursor++]; return e; } @Override public void remove() { if (lastRet < 0) throw new IllegalStateException();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 18.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchHelper.java
* * @param params The search request parameters * @param cursor Function to process each document in the result set * @param userBean Optional user information for permission checking * @return Total number of documents processed */ public long scrollSearch(final SearchRequestParams params, final BooleanFunction<Map<String, Object>> cursor, final OptionalThing<FessUserBean> userBean) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 35.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* @param condition the search condition * @param cursor the cursor function to process each hit * @return the number of documents processed * @throws InvalidQueryException if the query is invalid */ public long scrollSearch(final String index, final SearchCondition<SearchRequestBuilder> condition, final BooleanFunction<Map<String, Object>> cursor) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* href="https://developer.android.com/sdk/api_diff/16/">API Level 16</a> is the first version * in which {@code Cursor} is {@code Closeable}. To support older versions, pass a wrapper * {@code Closeable} with a method reference like {@code cursor::close}. * * <p>Note that this method is still binary-compatible between flavors because the erasure of
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 97.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
it.remove(); // After this remove, 400 has moved up and 20 down past cursor assertTrue("Heap is not intact after remove", mmHeap.isIntact()); assertEquals((Integer) 10, it.next()); assertEquals((Integer) 3, it.next()); it.remove(); // After this remove, 400 moved down again and 500 up past the cursor assertTrue("Heap is not intact after remove", mmHeap.isIntact());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 36K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 22.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java
} } /** * Exports all crawling information parameters to CSV format. * The CSV output includes: SessionId, SessionCreatedTime, Key, Value, CreatedTime. * Uses cursor-based selection to handle large datasets efficiently. * * @param writer the Writer to output CSV data to */ public void exportCsv(final Writer writer) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
* href="https://developer.android.com/sdk/api_diff/16/">API Level 16</a> is the first version * in which {@code Cursor} is {@code Closeable}. To support older versions, pass a wrapper * {@code Closeable} with a method reference like {@code cursor::close}. * * <p>Note that this method is still binary-compatible between flavors because the erasure of
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K bytes - Viewed (0)