- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 124 for unfinished (0.06 sec)
-
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
} catch (final Exception e) { logger.error("Could not delete old docs at {}", dataConfig, e); } } public boolean isFinished() { return finished; } public void stopCrawling() { if (dataStore != null) { dataStore.stop(); } }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt
import okio.BufferedSource import okio.ByteString internal open class BaseTestHandler : Http2Reader.Handler { override fun data( inFinished: Boolean, streamId: Int, source: BufferedSource, length: Int, ) { fail("") } override fun headers( inFinished: Boolean, streamId: Int, associatedStreamId: Int, headerBlock: List<Header>, ) { fail("") }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
tests/test_dependency_contextmanager.py
assert middleware_state["context_b"] == "finished b with a: started a" assert middleware_state["context_a"] == "finished a" assert middleware_state["bg"] == "not set" assert state["context_b"] == "finished b with a: started a" assert state["context_a"] == "finished a" assert state["bg"] == "bg set - b: finished b with a: started a - a: finished a" def test_sync_raise_raises():
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Aug 17 04:13:50 UTC 2024 - 11.6K bytes - Viewed (0) -
docs/contribute/debug_logging.md
[2020-01-01 00:00:00] Q10003 scheduled after 0 µs: OkHttp squareup.com onSettings [2020-01-01 00:00:00] Q10003 starting : OkHttp squareup.com onSettings [2020-01-01 00:00:00] Q10001 finished run in 3 ms: OkHttp squareup.com applyAndAckSettings [2020-01-01 00:00:00] Q10003 finished run in 528 µs: OkHttp squareup.com onSettings [2020-01-01 00:00:00] Q10000 scheduled after 0 µs: OkHttp ConnectionPool
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 2.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
@Throws(IOException::class) fun data( inFinished: Boolean, streamId: Int, source: BufferedSource, length: Int, ) /** * Create or update incoming headers, creating the corresponding streams if necessary. Frames * that trigger this are HEADERS and PUSH_PROMISE. * * @param inFinished true if the sender will not send further frames.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(NOT_ENOUGH_MS, DELAY_MS * 2)); // Is it still computing away anyway? assertThat(target.finished).isFalse(); MILLISECONDS.sleep(ENOUGH_MS); assertThat(target.finished).isFalse(); } public void testNewProxy_badMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.5K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
Header(":status", "404"), Header(":version", "HTTP/1.1"), Header("content-type", "text/plain"), ) stream.writeHeaders( responseHeaders = responseHeaders, outFinished = false, flushHeaders = false, ) val out = stream.getSink().buffer() out.writeUtf8("Not found: $path") out.close() } private fun serveDirectory( stream: Http2Stream,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
// Filled during heal. HealedBuckets []string // ID of the current healing operation HealID string ItemsSkipped uint64 BytesSkipped uint64 RetryAttempts uint64 Finished bool // finished healing, whether with errors or not // Add future tracking capabilities // Be sure that they are included in toHealingDisk } // loadHealingTracker will load the healing tracker from the supplied disk.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0)