Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for queueSize (0.03 sec)

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

        var messageCount: Long = 0
        while (true) {
          val success = webSocket.send(message)
          if (!success) break
          messageCount++
          val queueSize = webSocket.queueSize()
          assertThat(queueSize).isBetween(0L, messageCount * message.size)
          // Expect to fail before enqueueing 32 MiB.
          assertThat(messageCount).isLessThan(32L)
        }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            if (clickLogQueue.size() > fessConfig.getLoggingClickMaxQueueSizeAsInteger()) {
                logger.warn("Click log queue size exceeded: queueSize={}, limit={}. Skipped.", clickLogQueue.size(),
                        fessConfig.getLoggingClickMaxQueueSizeAsInteger());
                return;
            }
            clickLogQueue.add(clickLog);
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

      }
    
      @Test
      fun webSocket() {
        val webSocket =
          object : WebSocket {
            override fun request(): Request = TODO()
    
            override fun queueSize(): Long = TODO()
    
            override fun send(text: String): Boolean = TODO()
    
            override fun send(bytes: ByteString): Boolean = TODO()
    
            override fun close(
              code: Int,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 47K bytes
    - Viewed (0)
  4. okhttp/api/jvm/okhttp.api

    }
    
    public abstract interface class okhttp3/WebSocket {
    	public abstract fun cancel ()V
    	public abstract fun close (ILjava/lang/String;)Z
    	public abstract fun queueSize ()J
    	public abstract fun request ()Lokhttp3/Request;
    	public abstract fun send (Ljava/lang/String;)Z
    	public abstract fun send (Lokio/ByteString;)Z
    }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.2K bytes
    - Viewed (0)
  5. okhttp/api/android/okhttp.api

    }
    
    public abstract interface class okhttp3/WebSocket {
    	public abstract fun cancel ()V
    	public abstract fun close (ILjava/lang/String;)Z
    	public abstract fun queueSize ()J
    	public abstract fun request ()Lokhttp3/Request;
    	public abstract fun send (Ljava/lang/String;)Z
    	public abstract fun send (Lokio/ByteString;)Z
    }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.3K bytes
    - Viewed (0)
Back to top