- Sort Score
- Num 10 results
- Language All
Results 461 - 470 of 1,372 for carl (0.25 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava-tests/test/com/google/common/reflect/SubtypeTester.java
/** Suppresses the assertion on {@link TypeToken#getSupertype}. */ boolean suppressGetSupertype() default false; } private @Nullable Method method = null; /** Call this in a {@link TestSubtype} public method asserting subtype relationship. */ final <T> T isSubtype(T sub) { Type returnType = method.getGenericReturnType(); Type paramType = getOnlyParameterType();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:11:48 GMT 2026 - 6.1K bytes - Click Count (0) -
tensorflow/c/eager/c_api_experimental.h
// // This call may not block for execution of ops enqueued concurrently with this // call. TF_CAPI_EXPORT extern void TFE_ExecutorWaitForAllPendingNodes( TFE_Executor*, TF_Status* status); // When an error happens, any pending operations are discarded, and newly issued // ops return an error. This call clears the error state and re-enables // execution of newly issued ops. //
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 39.5K bytes - Click Count (1) -
internal/rest/client.go
return nil, errors.New(resp.Status) } if !c.NoMetrics { resp.Body = &respBodyMonitor{ReadCloser: resp.Body, expectTimeouts: expectTimeouts} } return resp.Body, nil } // Call - make a REST call with context. func (c *Client) Call(ctx context.Context, rpcMethod string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { return c.CallWithHTTPMethod(ctx, http.MethodPost, rpcMethod, values, body, length)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
* Process the next protocol frame. * * * If it is a control frame this will result in a single call to [FrameCallback]. * * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage]. * If the message spans multiple frames, each interleaved control frame will result in a * corresponding call to [FrameCallback]. */ @Throws(IOException::class) fun processNextFrame() {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10K bytes - Click Count (0) -
okcurl/src/main/kotlin/okhttp3/curl/logging/MessageFormatter.kt
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.curl.logging import java.util.logging.LogRecord import java.util.logging.SimpleFormatter object MessageFormatter : SimpleFormatter() { override fun format(record: LogRecord): String = String.format("%s%n", record.message)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 845 bytes - Click Count (0) -
.ci/templates.t/periodic-trigger-lgc.yml
- timed: "{cron}" builders: - shell: | #!/usr/bin/env bash set -o pipefail echo "Retrieving last good commit for job '{lgc-job}'" echo branch_specifier=$(curl -s "${JENKINS_URL}job/{lgc-job}/lastSuccessfulBuild/api/json" | jq -r -e '.actions | map(select(._class == "hudson.plugins.git.util.BuildData")) | .[] | .lastBuiltRevision.SHA1' || echo "refs/heads/%BRANCH%") > trigger.propertiesCreated: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Thu May 06 21:46:09 GMT 2021 - 1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
* FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}. * * <p>Few users should use this class. It is intended primarily for those who are implementing an * {@code ExecutorService}. Most users should call {@link ListeningExecutorService#submit(Callable) * ListeningExecutorService.submit} on a service obtained from {@linkCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 4.2K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Stopwatch.java
this.ticker = checkNotNull(ticker, "ticker"); } /** * Returns {@code true} if {@link #start()} has been called on this stopwatch, and {@link #stop()} * has not been called since the last call to {@code start()}. */ public boolean isRunning() { return isRunning; } /** * Starts the stopwatch. * * @return this {@code Stopwatch} instance
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 9.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SessionReuseTest.kt
.connectionSpecs(listOf(spec)) .eventListenerFactory( clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) { val sslSocket = connection.socket() as SSLSocket sessionIds.add( sslSocket.session.id
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 5.9K bytes - Click Count (1) -
android/guava-tests/test/com/google/common/base/StringsTest.java
} public void testPadStart_negativeMinLength() { assertThat(Strings.padStart("x", -1, '-')).isSameInstanceAs("x"); } @SuppressWarnings("nullness") // test of a bogus call public void testPadStart_null() { assertThrows(NullPointerException.class, () -> Strings.padStart(null, 5, '0')); } public void testPadEnd_noPadding() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 15:59:55 GMT 2026 - 11.4K bytes - Click Count (0)