Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 887 for closure (0.06 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt

          | * WebSocketListener
          |(It is safe to call contentType() and contentLength() on these response bodies.)
          """.trimMargin(),
        )
      }
    
      override fun timeout() = Timeout.NONE
    
      override fun close() {
      }
    }
    
    fun Response.stripBody(): Response {
      return newBuilder()
        .body(UnreadableResponseBody(body.contentType(), body.contentLength()))
        .build()
    }
    
    val Response.commonIsSuccessful: Boolean
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. cni/pkg/log/uds_test.go

    func TestUDSLog(t *testing.T) {
    	// Start UDS log server
    	udsSockDir := t.TempDir()
    	udsSock := filepath.Join(udsSockDir, "cni.sock")
    	logger := NewUDSLogger(istiolog.DebugLevel)
    	stop := make(chan struct{})
    	defer close(stop)
    	assert.NoError(t, logger.StartUDSLogServer(udsSock, stop))
    
    	// Configure log to tee to UDS server
    	stdout := os.Stdout
    	r, w, _ := os.Pipe()
    	os.Stdout = w
    	loggingOptions := istiolog.DefaultOptions()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/Streams.java

                      return true;
                    }
                    return false;
                  }
                },
                isParallel)
            .onClose(streamA::close)
            .onClose(streamB::close);
      }
    
      /**
       * Invokes {@code consumer} once for each pair of <i>corresponding</i> elements in {@code streamA}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http/ExternalHttp2Example.kt

          println("PROTOCOL ${response.protocol}")
          var line: String?
          while (response.body.source().readUtf8Line().also { line = it } != null) {
            println(line)
          }
        } finally {
          response.body.close()
        }
        client.connectionPool.evictAll()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                            indexUpdater.addFinishedSessionId(sid);
                            try {
                                crawler.close();
                            } catch (final Exception e) {
                                logger.warn("Failed to close the crawler.", e);
                            }
                        }
                        if (!Constants.DONE.equals(crawlerStatusList.get(i))) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CallTest.kt

        server.enqueue(
          MockResponse(
            code = 408,
            headers = headersOf("Connection", "Close"),
            body = "You took too long!",
            socketPolicy = DisconnectAtEnd,
          ),
        )
        server.enqueue(
          MockResponse(
            code = 408,
            headers = headersOf("Connection", "Close"),
            body = "You took too long!",
            socketPolicy = DisconnectAtEnd,
          ),
        )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/core/io/PropertiesUtilTest.java

            final FileOutputStream outputStream = OutputStreamUtil.create(file);
            PropertiesUtil.store(outProperties, outputStream, "comments");
            CloseableUtil.close(outputStream);
            final Properties properties = new Properties();
            PropertiesUtil.load(properties, file);
            assertThat(properties.getProperty("a"), is("A"));
        }
    
        /**
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/cni-watcher.go

    			// If the cniListener exits, at least we should record an error log
    			log.Errorf("CNI listener server exiting unexpectedly: %v", err)
    		}
    	}()
    
    	context.AfterFunc(s.ctx, func() {
    		if err := s.cniListenServer.Close(); err != nil {
    			log.Errorf("CNI listen server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI listen server terminated")
    		}
    	})
    	return nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. src/archive/zip/reader.go

    	dcomp := r.decompressors[method]
    	if dcomp == nil {
    		dcomp = decompressor(method)
    	}
    	return dcomp
    }
    
    // Close closes the Zip file, rendering it unusable for I/O.
    func (rc *ReadCloser) Close() error {
    	return rc.f.Close()
    }
    
    // DataOffset returns the offset of the file's possibly-compressed
    // data, relative to the beginning of the zip file.
    //
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. tests/test_http_connection_injection.py

    @app.websocket("/ws")
    async def get_value_by_ws(
        websocket: WebSocket, value: int = Depends(extract_value_from_http_connection)
    ):
        await websocket.accept()
        await websocket.send_json(value)
        await websocket.close()
    
    
    client = TestClient(app)
    
    
    def test_value_extracting_by_http():
        response = client.get("/http")
        assert response.status_code == 200
        assert response.json() == 42
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 09 13:56:41 UTC 2020
    - 972 bytes
    - Viewed (0)
Back to top