- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for closer (0.16 sec)
-
guava/src/com/google/common/util/concurrent/ClosingFuture.java
* * {@snippet : * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor) * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor) * .transform((closer, result) -> result.get("userName"), directExecutor())
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* * {@snippet : * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor) * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor) * .transform((closer, result) -> result.get("userName"), directExecutor())
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/io/testdata/alice_in_wonderland.txt
`Tut, tut, child!' said the Duchess. `Everything's got a moral, if only you can find it.' And she squeezed herself up closer to Alice's side as she spoke. Alice did not much like keeping so close to her: first, because the Duchess was VERY ugly; and secondly, because she was exactly the right height to rest her chin upon Alice's shoulder, and it was an uncomfortably sharp chin. However, she did not
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 145.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
.assertFailure("canceled", "Canceled", "Socket closed", "Socket is closed") } @Test fun cancelAll() { val call = client.newCall(Request(server.url("/"))) call.enqueue(callback) client.dispatcher.cancelAll() callback .await(server.url("/")) .assertFailure("canceled", "Canceled", "Socket closed", "Socket is closed") } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
* characters can be read, the remaining characters are returned and the stream is closed. */ private fun readAscii( inputStream: InputStream, count: Int, ): String { val result = StringBuilder() for (i in 0 until count) { val value = inputStream.read() if (value == -1) { inputStream.close() break } result.append(value.toChar()) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
} final Smb2CloseRequest closeReq = new Smb2CloseRequest(th.getConfig(), Smb2Constants.UNSPECIFIED_FILEID); closeReq.setCloseFlags(Smb2CloseResponse.SMB2_CLOSE_FLAG_POSTQUERY_ATTIB); cur.chain(closeReq); final Smb2CreateResponse createResp = th.send(cr); final Smb2CloseResponse closeResp = closeReq.getResponse(); SmbBasicFileInfo info;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 103.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
} void close(final int f, final long lastWriteTime) throws SmbException { if (LogStream.level >= 3) { log.println("close: " + f); } /* * Close Request / Response */ send(new SmbComClose(f, lastWriteTime), blank_resp()); } void close(final long lastWriteTime) throws SmbException {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 112.2K bytes - Viewed (0) -
src/main/webapp/js/admin/adminlte.min.js.map
is._config.title))\n }\n\n if (this._config.subtitle != null) {\n toastHeader.append($('<small />').html(this._config.subtitle))\n }\n\n if (this._config.close == true) {\n const toastClose = $('<button data-dismiss=\"toast\" />').attr('type', 'button').addClass('ml-2 mb-1 close').attr('aria-label', 'Close').append('<span aria-hidden=\"true\">×</span>')\n\n if (this._config.title == null) {\n toastClose.toggleClass('ml-2 ml-auto')\n }\n\n toastHe...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 132.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
response.body.string() val cached = cacheGet(cache, request) if (shouldWriteToCache) { assertThat(cached).isNotNull() cached!!.body.close() } else { assertThat(cached).isNull() } server.close() // tearDown() isn't sufficient; this test starts multiple servers } private fun assertSubsequentResponseCached( initialResponseCode: Int,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 113.6K bytes - Viewed (0) -
src/main/webapp/css/bootstrap.min.css
tn-close-hover-opacity)}.btn-close:focus{outline:0;box-shadow:var(--bs-btn-close-focus-shadow);opacity:var(--bs-btn-close-focus-opacity)}.btn-close.disabled,.btn-close:disabled{pointer-events:none;-webkit-user-select:none;-moz-user-select:none;user-select:none;opacity:var(--bs-btn-close-disabled-opacity)}.btn-close-white{filter:var(--bs-btn-close-white-filter)}[data-bs-theme=dark] .btn-close{filter:var(--bs-btn-close-white-filter)}.toast{--bs-toast-zindex:1090;--bs-toast-padding-x:0.75rem;--bs-t...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Jan 12 06:14:02 UTC 2025 - 227.5K bytes - Viewed (0)