Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 522 for mask (0.02 seconds)

  1. 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)
  2. 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)
  3. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractEntity.java

            return false;
        }
    
        // ===================================================================================
        //                                                                     Birthplace Mark
        //                                                                     ===============
        @Override
        public void markAsSelect() {
            __createdBySelect = true;
        }
    
        @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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 information
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. 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)
  9. 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? = null
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  10. 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)
Back to Top