Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for onClosed (0.14 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt

          events.add(Closing(code, reason))
        }
      }
    
      override fun onClosed(
        webSocket: WebSocket,
        code: Int,
        reason: String,
      ) {
        Platform.get().log("[WS $name] onClosed $code", Platform.INFO, null)
        val delegate = delegate
        if (delegate != null) {
          this.delegate = null
          delegate.onClosed(webSocket, code, reason)
        } else {
          events.add(Closed(code, reason))
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 6.8K bytes
    - Click Count (0)
  2. okhttp/api/android/okhttp.api

    	public abstract fun newWebSocket (Lokhttp3/Request;Lokhttp3/WebSocketListener;)Lokhttp3/WebSocket;
    }
    
    public abstract class okhttp3/WebSocketListener {
    	public fun <init> ()V
    	public fun onClosed (Lokhttp3/WebSocket;ILjava/lang/String;)V
    	public fun onClosing (Lokhttp3/WebSocket;ILjava/lang/String;)V
    	public fun onFailure (Lokhttp3/WebSocket;Ljava/lang/Throwable;Lokhttp3/Response;)V
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 72.3K bytes
    - Click Count (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}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.4K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/collect/RangeTest.java

        // overlap below
        assertEquals(Range.closed(4, 6), range.intersection(Range.closed(2, 6)));
    
        // enclosed with same start
        assertEquals(Range.closed(4, 6), range.intersection(Range.closed(4, 6)));
    
        // enclosed, interior
        assertEquals(Range.closed(5, 7), range.intersection(Range.closed(5, 7)));
    
        // enclosed with same end
        assertEquals(Range.closed(6, 8), range.intersection(Range.closed(6, 8)));
    
        // equal
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 24.4K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/reflect/Invokable.java

          if (declaringClass.getEnclosingConstructor() != null) {
            // Enclosed in a constructor, needs hidden this
            return true;
          }
          Method enclosingMethod = declaringClass.getEnclosingMethod();
          if (enclosingMethod != null) {
            // Enclosed in a method, if it's not static, must need hidden this.
            return !Modifier.isStatic(enclosingMethod.getModifiers());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 18.5K bytes
    - Click Count (0)
  6. tests/test_tutorial/test_body/test_tutorial001.py

                {
                    "type": "json_invalid",
                    "loc": ["body", 1],
                    "msg": "JSON decode error",
                    "input": {},
                    "ctx": {"error": "Expecting property name enclosed in double quotes"},
                }
            ]
        }
    
    
    def test_post_form_for_json(client: TestClient):
        response = client.post("/items/", data={"name": "Foo", "price": 50.5})
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Feb 23 17:45:20 GMT 2026
    - 11.1K bytes
    - Click Count (0)
  7. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

        val pushedConstructed = constructed
    
        val newLimit = if (header.length != -1L) byteCount + header.length else -1L
        if (pushedLimit != -1L && newLimit > pushedLimit) {
          throw ProtocolException("enclosed object too large")
        }
    
        limit = newLimit
        constructed = header.constructed
        if (name != null) path += name
        try {
          val result = block(header)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/util/GsaConfigParserTest.java

            }
        }
    
        @Test
        public void test_parseWithMalformedXml() {
            GsaConfigParser parser = new GsaConfigParser();
            String malformedXml = "<?xml version=\"1.0\"?><eef><unclosed>";
    
            try {
                parser.parse(new InputSource(new StringReader(malformedXml)));
                fail("Should throw GsaConfigException");
            } catch (GsaConfigException e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 11.7K bytes
    - Click Count (0)
  9. doc/go_spec.html

    ()  grouping
    []  option (0 or 1 times)
    {}  repetition (0 to n times)
    </pre>
    
    <p>
    Lowercase production names are used to identify lexical (terminal) tokens.
    Non-terminals are in CamelCase. Lexical tokens are enclosed in
    double quotes <code>""</code> or back quotes <code>``</code>.
    </p>
    
    <p>
    The form <code>a … b</code> represents the set of characters from
    <code>a</code> through <code>b</code> as alternatives. The horizontal
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Apr 01 23:39:18 GMT 2026
    - 287.8K bytes
    - Click Count (1)
Back to Top