- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 522 for mask (0.02 seconds)
-
build-tools-internal/src/integTest/java/org/elasticsearch/gradle/internal/ExportElasticsearchBuildResourcesTaskIT.java
assertOutputContains( getGradleRunner().withArguments("noConfigAfterExecution", "-s", "-i").buildAndFail().getOutput(), "buildResources can't be configured after the task ran" ); }
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 2.2K bytes - Click Count (0) -
docs/zh-hant/docs/tutorial/background-tasks.md
**FastAPI** 會為你建立 `BackgroundTasks` 物件,並以該參數傳入。 ## 建立任務函式 { #create-a-task-function } 建立一個作為背景任務執行的函式。 它只是個可接收參數的一般函式。 它可以是 `async def`,也可以是一般的 `def`,**FastAPI** 都能正確處理。 在此例中,任務函式會寫入檔案(模擬寄送電子郵件)。 由於寫入操作未使用 `async` 與 `await`,因此以一般的 `def` 定義該函式: {* ../../docs_src/background_tasks/tutorial001_py310.py hl[6:9] *} ## 新增背景任務 { #add-the-background-task } 在路徑操作函式內,使用 `.add_task()` 將任務函式加入背景任務物件:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:05:38 GMT 2026 - 4.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractEntity.java
return false; } // =================================================================================== // Birthplace Mark // =============== @Override public void markAsSelect() { __createdBySelect = true; } @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 10.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
private val sinkBuffer: Buffer = sink.buffer private var writerClosed = false /** Lazily initialized on first use. */ private var messageDeflater: MessageDeflater? = null // Masks are only a concern for client writers. private val maskKey: ByteArray? = if (isClient) ByteArray(4) else null private val maskCursor: Buffer.UnsafeCursor? = if (isClient) Buffer.UnsafeCursor() else null
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 6K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ResolveAllDependencies.java
.from(configs.stream().filter(ResolveAllDependencies::canBeResolved).collect(Collectors.toList())); } @TaskAction void resolveAll() { // do nothing, dependencies are resolved when snapshotting task inputs } private static boolean canBeResolved(Configuration configuration) { if (configuration.isCanBeResolved() == false) { return false; }
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 2.3K bytes - Click Count (0) -
tests/test_custom_route_class.py
router_b.include_router(router=router_c, prefix="/c") router_a.include_router(router=router_b, prefix="/b") app.include_router(router=router_a, prefix="/a") client = TestClient(app) @pytest.mark.parametrize( "path,expected_status,expected_response", [ ("/a", 200, {"msg": "A"}), ("/a/b", 200, {"msg": "B"}), ("/a/b/c", 200, {"msg": "C"}), ], )
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Feb 08 10:18:38 GMT 2026 - 3.3K bytes - Click Count (0) -
src/main/java/jcifs/util/Strings.java
len++; if (len > maxLen) { throw new RuntimeCIFSException("zero termination not found"); } } return len; } /** * Masks sensitive values in a string for security purposes. * * @param value the string potentially containing sensitive informationCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.5K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/ExecJobTest.java
// Test with timeout set execJob.timeout = 10; execJob.sessionId = "test-session"; TimeoutTask task = execJob.testCreateTimeoutTask(); assertNotNull(task); // Clean up timeout task task.cancel(); } // Test createSystemProperties method @Test public void test_createSystemProperties() throws IOException {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 24.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
Lockable { private val key: String /** Non-null for client web sockets. These can be canceled. */ internal var call: Call? = null /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */ private var writerTask: Task? = null /** Null until this web socket is connected. Only accessed by the reader thread. */ private var reader: WebSocketReader? = nullCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 21.6K bytes - Click Count (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilder.java
} public PluginDescriptor build(ReaderSupplier readerSupplier, String source) throws PlexusConfigurationException { try (BufferedReader br = new BufferedReader(readerSupplier.open(), BUFFER_SIZE)) { br.mark(BUFFER_SIZE); XMLStreamReader xsr = XMLInputFactory.newFactory().createXMLStreamReader(br); xsr.nextTag(); String nsUri = xsr.getNamespaceURI();Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Mar 25 09:45:07 GMT 2025 - 17.5K bytes - Click Count (0)