Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for emitf (1.14 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt

          }
        }
        when (selectedMethod) {
          METHOD_NO_AUTHENTICATION_REQUIRED -> {
            fromSink.writeByte(VERSION_5)
            fromSink.writeByte(selectedMethod)
            fromSink.emit()
          }
          else -> throw ProtocolException("unsupported method: $selectedMethod")
        }
      }
    
      private fun acceptCommand(
        fromAddress: InetAddress,
        fromSource: BufferedSource,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  2. internal/s3select/jstream/README.md

    0	000	155	array  | [{"colors":["red","green","blue"],"desc":"RGB"},{"colors":["cyan","magenta","yellow","black"],"desc":"CMYK"}]
    ```
    
    ### Options
    
    Opt | Description
    --- | ---
    -d \<n\> | emit values at depth n. if n < 0, all values will be emitted
    -kv | output inner key value pairs as newly formed objects
    -v | output depth and offset details for each value
    -h | display help dialog
    
    ## Benchmarks
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/logging/AccumulatingLogger.java

    import org.apache.maven.api.cli.Logger;
    
    import static java.util.Objects.requireNonNull;
    
    /**
     * Early CLI {@link Logger} that simply accumulates log entries until some point a real logger can emit them. This
     * logger is created at start, and it exists while no logging is available yet.
     */
    public class AccumulatingLogger implements Logger {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jan 31 20:56:58 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      private val minimumDeflateSize: Long,
    ) : Closeable {
      /** This holds outbound data for compression and masking. */
      private val messageBuffer = Buffer()
    
      /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
      private val sinkBuffer: Buffer = sink.buffer
      private var writerClosed = false
    
      /** Lazily initialized on first use. */
      private var messageDeflater: MessageDeflater? = null
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6K bytes
    - Viewed (0)
Back to top