Search Options

Results per page
Sort
Preferred Languages
Advance

Results 691 - 700 of 1,156 for calls (0.13 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          isTlsFallback = isTlsFallback,
        )
    
      override fun connectTcp(): ConnectResult {
        check(rawSocket == null) { "TCP already connected" }
    
        var success = false
    
        // Tell the call about the connecting call so async cancels work.
        user.addPlanToCancel(this)
        try {
          user.connectStart(route)
    
          connectSocket()
          success = true
          return ConnectResult(plan = this)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/TrailersSource.kt

     * Implementations of this interface should respond to [Call.cancel] by immediately throwing an
     * [IOException].
     *
     * Most callers won't need this interface, and should use [Response.trailers] instead.
     *
     * This interface is for test and production code that creates [Response] instances without making
     * an HTTP call to a remote server.
     */
    interface TrailersSource {
      @Throws(IOException::class)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  3. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt

      @Throws(InterruptedException::class)
      override fun dispatch(request: RecordedRequest): MockResponse = throw UnsupportedOperationException("unexpected call")
    
      override fun peek(): MockResponse = throw UnsupportedOperationException("unexpected call")
    
      fun enqueueResponse(response: MockResponse) {
        delegate.enqueue(response.wrap())
      }
    
      override fun shutdown() {
        delegate.close()
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 14 16:09:26 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/graph/AbstractDirectedNetworkConnections.java

        // (We're relying on callers to call this method only with an edge that's in the graph.)
        return requireNonNull(outEdgeMap.get(edge));
      }
    
      @Override
      public N removeInEdge(E edge, boolean isSelfLoop) {
        if (isSelfLoop) {
          checkNonNegative(--selfLoopCount);
        }
        N previousNode = inEdgeMap.remove(edge);
        // We're relying on callers to call this method only with an edge that's in the graph.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  5. src/test/java/jcifs/dcerpc/msrpc/SamrAliasHandleTest.java

            // Mock close success for the first call
            doAnswer(invocation -> {
                MsrpcSamrCloseHandle rpc = invocation.getArgument(0);
                rpc.retval = 0;
                return null;
            }).when(mockDcerpcHandle).sendrecv(any(MsrpcSamrCloseHandle.class));
    
            // First close call
            aliasHandle.close();
    
            // Act: Call close again
            aliasHandle.close();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/SmbResourceLocatorImplTest.java

            }
        }
    
        private SmbResourceLocatorImpl locator(String spec) {
            return new SmbResourceLocatorImpl(ctx, smbUrl(spec));
        }
    
        @Test
        @DisplayName("getName returns last path segment; falls back logically")
        void testGetNameVariants() {
            // file name from deep path
            SmbResourceLocatorImpl a = locator("smb://server/share/dir/file.txt");
            assertEquals("file.txt", a.getName());
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  7. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.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.sse
    
    import okhttp3.Call
    import okhttp3.OkHttpClient
    import okhttp3.Response
    import okhttp3.sse.EventSource.Companion.processEventSource
    import okhttp3.sse.EventSource.Factory.Companion.asEventSourceFactory
    
    object EventSources {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/eventbus/StringCatcher.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A simple EventSubscriber mock that records Strings.
     *
     * <p>For testing fun, also includes a landmine method that EventBus tests are required not
     * to call ({@link #methodWithoutAnnotation(String)}).
     *
     * @author Cliff Biffle
     */
    @NullUnmarked
    public class StringCatcher {
      private final List<String> events = new ArrayList<>();
    
      @Subscribe
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  9. cmd/dummy-handlers.go

    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	// Allow GetBucketWebsite if policy action is set, since this is a dummy call
    	// we are simply re-purposing the bucketPolicyAction.
    	if s3Error := checkRequestAuthType(ctx, r, policy.GetBucketPolicyAction, bucket, ""); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  10. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/EventListener;->requestBodyStart(Lokhttp3/Call;)V
    HSPLokhttp3/EventListener;->requestHeadersEnd(Lokhttp3/Call;Lokhttp3/Request;)V
    HSPLokhttp3/EventListener;->requestHeadersStart(Lokhttp3/Call;)V
    HSPLokhttp3/EventListener;->responseBodyEnd(Lokhttp3/Call;J)V
    HSPLokhttp3/EventListener;->responseBodyStart(Lokhttp3/Call;)V
    HSPLokhttp3/EventListener;->responseHeadersEnd(Lokhttp3/Call;Lokhttp3/Response;)V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
Back to top