- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 40 for emitf (0.09 seconds)
-
src/cmd/api/main_test.go
case *types.Const: if w.isDeprecated(obj) { w.emitf("const %s //deprecated", obj.Name()) } w.emitf("const %s %s", obj.Name(), w.typeString(obj.Type())) x := obj.Val() short := x.String() exact := x.ExactString() if short == exact { w.emitf("const %s = %s", obj.Name(), short) } else { w.emitf("const %s = %s // %s", obj.Name(), short, exact) } case *types.Var:
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Mar 02 13:20:41 GMT 2026 - 31.4K bytes - Click Count (0) -
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,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 7.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
server.webSocket!!.finishReader() server.listener.assertClosed(1000, "Bye!") } @Test fun emptyCloseInitiatesShutdown() { server.sink.write("8800".decodeHex()).emit() // Close without code. client.processNextFrame() client.listener.assertClosing(1005, "") client.webSocket!!.finishReader() assertThat(client.webSocket!!.close(1000, "Bye!")).isTrue()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 18.7K bytes - Click Count (0) -
build-tools-internal/src/main/groovy/org/elasticsearch/gradle/internal/doc/SnippetsTask.groovy
if (snippet != null && line.trim() == '+') { return } // Just finished emit() } if (snippet != null) emit() } } static Source matchSource(String line) { def matcher = line =~ /\["?source"?,\s*"?([-\w]+)"?(,((?!id=).)*(id="?([-\w]+)"?)?(.*))?].*/
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Sep 20 10:08:26 GMT 2021 - 17.8K bytes - Click Count (0) -
internal/s3select/jstream/decoder.go
// at configured emit depth are within a JSON object. By default, only // the object values are emitted. func (d *Decoder) EmitKV() *Decoder { d.emitKV = true return d } // Recursive enables emitting all values at a depth higher than the // configured emit depth; e.g. if an array is found at emit depth, all // values within the array are emitted to the stream, then the array
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
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 {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jan 31 20:56:58 GMT 2025 - 1.7K bytes - Click Count (0) -
build-tools-internal/src/main/groovy/org/elasticsearch/gradle/internal/AntTask.groovy
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 3.4K bytes - Click Count (0) -
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 ## BenchmarksCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 3.2K bytes - Click Count (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Options.java
* @return a new {@link Options} instance with interpolated values */ @Nonnull Options interpolate(@Nonnull UnaryOperator<String> callback); /** * Emits warning messages if deprecated options are used. * * @param printWriter the string consumer to use for output */Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Mon Jan 13 16:14:35 GMT 2025 - 6.5K bytes - Click Count (0) -
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? = nullCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 6K bytes - Click Count (0)