- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 761 for confirm (0.18 sec)
-
internal/grid/muxserver.go
m.handleInbound(c, inbound, handlerIn) }(m.inbound) } // Fill outbound block. // Each token represents a message that can be sent to the client without blocking. // The client will refill the tokens as they confirm delivery of the messages. for i := 0; i < outboundCap; i++ { m.outBlock <- struct{}{} } // Handler goroutine. var handlerErr atomic.Pointer[RemoteErr] go func() { wg.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RequestCommonTest.kt
assertThat(request.tag(String::class)).isSameAs(stringTag) // TODO check for Jvm or handle Long/long correctly // assertThat(request.tag(Long::class)).isSameAs(longTag) } /** Confirm that we don't accidentally share the backing map between objects. */ @Test fun tagsAreImmutable() { val builder = Request.Builder() .url("https://square.com")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
) serverIpv4.enqueue( MockResponse(body = "this was the 2nd request on IPv4"), ) serverIpv6.enqueue( MockResponse(body = "unexpected call to IPv6"), ) // Confirm the retry succeeds on the same connection. val call = client.newCall(Request(url)) val response = call.execute() assertThat(response.body.string()).isEqualTo("this was the 2nd request on IPv4")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
src/main/resources/fess_label_ru.properties
labels.reqheader_configuration=Request Header labels.reqheader_list_name=Name labels.reqheader_list_web_crawling_config=Config Name labels.reqheader_create_web_config=Create New Web Config labels.reqheader_title_details=Request Header labels.reqheader_name=Name labels.reqheader_value=Value labels.reqheader_web_crawling_config=Web Config labels.key_match_configuration=Key Match labels.key_match_list_term=Term labels.key_match_list_query=Query
Properties - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Fri Mar 22 11:58:34 GMT 2024 - 45.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
taskRunner.lock.withLock { check(currentTask == TestThreadSerialTask) nanoTime = newTime yieldUntil(ResumePriority.AfterOtherTasks) } } /** Confirm all tasks have completed. Used by the test thread only. */ fun assertNoMoreTasks() { taskRunner.assertThreadDoesntHoldLock() taskRunner.lock.withLock { assertThat(activeThreads).isEqualTo(0) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
src/main/resources/fess_label_fr.properties
labels.oldPassword = Mot de passe actuel labels.newPassword = nouveau mot de passe labels.confirmNewPassword = Nouveau mot de passe (confirmer) labels.menu_system = Système labels.menu_wizard = Assistant labels.menu_crawl_config = Général labels.menu_scheduler_config = Planificateur labels.menu_dashboard_config = Tableau de bord labels.menu_design = Conception de pages labels.menu_dict = Dictionnaire
Properties - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Fri Mar 22 11:58:34 GMT 2024 - 46.6K bytes - Viewed (0) -
src/main/resources/fess_label_ja.properties
labels.ex_q=拡張クエリー labels.oldPassword=現在のパスワード labels.newPassword=新しいパスワード labels.confirmNewPassword=新しいパスワード(確認) labels.menu_system=システム labels.menu_wizard=ウィザード labels.menu_crawl_config=全般 labels.menu_scheduler_config=スケジューラ labels.menu_dashboard_config=ダッシュボード labels.menu_design=ページのデザイン labels.menu_dict=辞書 labels.menu_data=バックアップ/復元 labels.menu_crawl=クローラー labels.menu_web=ウェブ labels.menu_file_system=ファイルシステム
Properties - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Fri Mar 22 11:58:34 GMT 2024 - 46.2K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
val parts = MultipartReader( boundary = "simple boundary", source = Buffer(), ) assertFailsWith<EOFException> { parts.nextPart() } } /** Confirm that [MultipartBody] and [MultipartReader] can work together. */ @Test fun `multipart round trip`() { val body = MultipartBody.Builder("boundary") .setType(MultipartBody.PARALLEL)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if target.client != nil { return nil } clientV7, err := newClientV7(target.args) if err != nil { return err } // Check es version to confirm if it is supported. serverSupportStatus, version, err := clientV7.getServerSupportStatus(ctx) if err != nil { return err } switch serverSupportStatus { case ESSUnknown:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/searchlist/AdminSearchlistAction.java
public static void validateFields(final CreateForm form, final Consumer<VaMessenger<FessMessages>> throwError) { final FessConfig fessConfig = ComponentUtil.getFessConfig(); try { if (!fessConfig.validateIndexRequiredFields(form.doc)) { throwError.accept(messages -> fessConfig.invalidIndexRequiredFields(form.doc).stream().map(s -> "doc." + s)
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.4K bytes - Viewed (0)