Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for onClosing (0.06 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

                return
              }
    
              // Apply the extensions. If they're unacceptable initiate a graceful shut down.
              // TODO(jwilson): Listeners should get onFailure() instead of onClosing() + onClosed(1010).
              val extensions = WebSocketExtensions.parse(response.headers)
              ******@****.***ions = extensions
              if (!extensions.isValid()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        clientListener.assertOpen()
        val server = serverListener.assertOpen()
        val e = RuntimeException()
        clientListener.setNextEventDelegate(
          object : WebSocketListener() {
            override fun onClosing(
              webSocket: WebSocket,
              code: Int,
              reason: String,
            ) {
              throw e
            }
          },
        )
        server.close(1000, "bye")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt

              text: String,
            ) = TODO()
    
            override fun onMessage(
              webSocket: WebSocket,
              bytes: ByteString,
            ) = TODO()
    
            override fun onClosing(
              webSocket: WebSocket,
              code: Int,
              reason: String,
            ) = TODO()
    
            override fun onClosed(
              webSocket: WebSocket,
              code: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/RangeTest.java

        // equal
        assertEquals(range, range.intersection(range));
    
        // enclosing with same start
        assertEquals(range, range.intersection(Range.closed(4, 10)));
    
        // enclosing with same end
        assertEquals(range, range.intersection(Range.closed(2, 8)));
    
        // enclosing, exterior
        assertEquals(range, range.intersection(Range.closed(2, 10)));
    
        // overlap above
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  5. internal/s3select/sql/parser.go

    	return nil
    }
    
    // LiteralString is a type for parsed SQL string literals
    type LiteralString string
    
    // Capture interface used by participle
    func (ls *LiteralString) Capture(values []string) error {
    	// Remove enclosing single quote
    	n := len(values[0])
    	r := values[0][1 : n-1]
    	// Translate doubled quotes
    	*ls = LiteralString(strings.ReplaceAll(r, "''", "'"))
    	return nil
    }
    
    // LiteralList is a type for parsed SQL lists literals
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/CollectCollectors.java

            EnumSetAccumulator::add,
            EnumSetAccumulator::combine,
            EnumSetAccumulator::toImmutableSet,
            Collector.Characteristics.UNORDERED);
      }
    
      @IgnoreJRERequirement // see enclosing class (whose annotation Animal Sniffer ignores here...)
      private static final class EnumSetAccumulator<E extends Enum<E>> {
        @SuppressWarnings({"rawtypes", "unchecked"})
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/reflect/Invokable.java

       * Returns all declared parameters of this {@code Invokable}. Note that if this is a constructor
       * of a non-static inner class, unlike {@link Constructor#getParameterTypes}, the hidden {@code
       * this} parameter of the enclosing class is excluded from the returned parameters.
       */
      @IgnoreJRERequirement
      public final ImmutableList<Parameter> getParameters() {
        Type[] parameterTypes = getGenericParameterTypes();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

          constructed = pushedConstructed
          if (name != null) path.removeAt(path.size - 1)
        }
      }
    
      /**
       * Execute [block] with a new namespace for type hints. Type hints from the enclosing type are no
       * longer usable by the current type's members.
       */
      fun <T> withTypeHint(block: () -> T): T {
        typeHintStack.add(null)
        try {
          return block()
        } finally {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  9. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt

          )
        }.also { expected ->
          assertThat(expected).hasMessage("indefinite length not permitted for DER")
        }
      }
    
      @Test fun `cannot decode constructed octet string in enclosing sequence`() {
        val buffer =
          Buffer()
            .write("3A0904034A6F6E04026573".decodeHex())
        val derReader = DerReader(buffer)
        assertFailsWith<Exception> {
          derReader.read("test") {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/TempFileCreator.java

                  /* prefix= */ prefix,
                  /* suffix= */ null,
                  filePermissions.get())
              .toFile();
        }
    
        @IgnoreJRERequirement // see enclosing class (whose annotation Animal Sniffer ignores here...)
        private interface PermissionSupplier {
          FileAttribute<?> get() throws IOException;
        }
    
        private static final PermissionSupplier filePermissions;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 06 17:11:11 UTC 2023
    - 12.5K bytes
    - Viewed (0)
Back to top