Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 887 for closure (0.06 sec)

  1. internal/grid/connection.go

    					return
    				}
    			}
    		}
    	}()
    	// Close all active requests.
    	if debugReqs {
    		fmt.Println(c.String(), "Reconnected. Clearing outgoing.")
    	}
    	c.outgoing.Range(func(key uint64, client *muxClient) bool {
    		client.close()
    		return true
    	})
    	c.inStream.Range(func(key uint64, value *muxServer) bool {
    		value.close()
    		return true
    	})
    
    	c.inStream.Clear()
    	c.outgoing.Clear()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. scripts/playwright/header_param_models/image01.py

        # Manually add the screenshot
        page.screenshot(path="docs/en/docs/img/tutorial/header-param-models/image01.png")
    
        # ---------------------
        context.close()
        browser.close()
    
    
    process = subprocess.Popen(
        ["fastapi", "run", "docs_src/header_param_models/tutorial001.py"]
    )
    try:
        for _ in range(3):
            try:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  3. scripts/playwright/request_form_models/image01.py

        # Manually add the screenshot
        page.screenshot(path="docs/en/docs/img/tutorial/request-form-models/image01.png")
    
        # ---------------------
        context.close()
        browser.close()
    
    
    process = subprocess.Popen(
        ["fastapi", "run", "docs_src/request_form_models/tutorial001.py"]
    )
    try:
        for _ in range(3):
            try:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Sep 13 09:14:46 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/TestInputStream.java

        throwIf(closed);
        return options.contains(TestOption.AVAILABLE_ALWAYS_ZERO) ? 0 : in.available();
      }
    
      @Override
      public void close() throws IOException {
        closed = true;
        throwIf(CLOSE_THROWS);
        in.close();
      }
    
      private void throwIf(TestOption option) throws IOException {
        throwIf(options.contains(option));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.5K bytes
    - Viewed (0)
  5. internal/http/listener_test.go

    		for _, serverAddr := range listener.Addrs() {
    			conn, err := net.Dial("tcp", serverAddr.String())
    			if err != nil {
    				t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err)
    			}
    			conn.Close()
    		}
    
    		listener.Close()
    	}
    }
    
    func TestHTTPListenerAddr(t *testing.T) {
    	if runtime.GOOS == "windows" {
    		t.Skip()
    	}
    
    	nonLoopBackIP := getNonLoopBackIP(t)
    	var casePorts []string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt

            .url(server.url("/"))
            .header("Connection", "close")
            .build()
        val requestB = Request(server.url("/"))
        assertConnectionNotReused(requestA, requestB)
      }
    
      @Test
      fun connectionsAreNotReusedWithResponseConnectionClose() {
        server.enqueue(
          MockResponse(
            headers = headersOf("Connection", "close"),
            body = "a",
          ),
        )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

       * hosting filesystem becomes unreachable, the iterator will omit elements rather than throwing
       * exceptions.
       *
       * **The caller must [close][Snapshot.close]** each snapshot returned by [Iterator.next]. Failing
       * to do so leaks open files!
       */
      @Synchronized
      @Throws(IOException::class)
      fun snapshots(): MutableIterator<Snapshot> {
        initialize()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientCreator.java

                    logger.info("{} is not available.", componentName);
                }
                if (client != null) {
                    try {
                        client.close();
                    } catch (final Exception ex) {
                        logger.warn("Failed to close {}.", componentName, ex);
                    }
                }
            }
        }
    
        public void setMaxClientFactorySize(final int maxClientFactorySize) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. fastapi/datastructures.py

            """
            return await super().seek(offset)
    
        async def close(self) -> None:
            """
            Close the file.
    
            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().close()
    
        @classmethod
        def __get_validators__(cls: Type["UploadFile"]) -> Iterable[Callable[..., Any]]:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                new Thread(() -> {
                    try {
                        CloseableUtil.closeQuietly(process.getInputStream());
                    } catch (final Exception e) {
                        logger.warn("Could not close a process input stream.", e);
                    } finally {
                        latch.countDown();
                    }
                }, "ProcessCloser-input-" + sessionId).start();
                new Thread(() -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 6.4K bytes
    - Viewed (0)
Back to top