- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 941 for emit (0.24 sec)
-
okhttp/src/main/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
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/test/java/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,
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/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()
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 16.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
byteCount: Long, ) { ******@****.***ThreadDoesntHoldLock() sendBuffer.write(source, byteCount) while (sendBuffer.size >= EMIT_BUFFER_SIZE) { emitFrame(false) } } /** * Emit a single data frame to the connection. The frame's size be limited by this stream's * write window. This method will block until the write window is nonempty. */
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.2K bytes - Viewed (1) -
src/main/webapp/js/clipboard.min.js
function(){this.selectedText=(0,c.default)(this.target),this.copyText()}},{key:"copyText",value:function(){var e=void 0;try{e=document.execCommand(this.action)}catch(t){e=!1}this.handleResult(e)}},{key:"handleResult",value:function(t){this.emitter.emit(t?"success":"error",{action:this.action,text:this.selectedText,trigger:this.trigger,clearSelection:this.clearSelection.bind(this)})}},{key:"clearSelection",value:function(){this.trigger&&this.trigger.focus(),window.getSelection().removeAllRanges()...
JavaScript - Registered: Mon Mar 25 08:04:08 GMT 2024 - Last Modified: Sat May 28 04:16:16 GMT 2022 - 10.5K bytes - Viewed (2) -
istioctl/pkg/authz/testdata/configdump.yaml
{ "name": "envoy.filters.http.grpc_stats", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.filters.http.grpc_stats.v3.FilterConfig", "emit_filter_state": true, "stats_for_all_methods": false } }, { "name": "istio.alpn", "typed_config": {
Others - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Wed Jun 21 14:20:23 GMT 2023 - 206.7K bytes - Viewed (2) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirResolveExtensionInfoProvider.kt
emptySequence() } override fun getPackageSymbols(nameFilter: KtScopeNameFilter): Sequence<KtPackageSymbol> = withValidityAssertion { sequence { // Only emit package symbols for top-level packages (subpackages of root). This matches the behavior // of the root-level KtFirPackageScope. val seenTopLevelPackages = mutableSetOf<Name>()
Plain Text - Registered: Fri Mar 29 08:18:10 GMT 2024 - Last Modified: Fri Jul 14 17:32:09 GMT 2023 - 5.6K bytes - Viewed (0) -
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:
Go - Registered: Tue Mar 26 11:13:08 GMT 2024 - Last Modified: Fri Jan 26 19:39:32 GMT 2024 - 31.4K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/testdata/config_dump.json
"typed_config": { "@type": "type.googleapis.com/envoy.extensions.filters.http.grpc_stats.v3.FilterConfig", "emit_filter_state": true, "stats_for_all_methods": false } }, {
Json - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Wed Jan 03 23:08:06 GMT 2024 - 54.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt
if (currentRunLength > longestRunLength && currentRunLength >= 4) { longestRunOffset = currentRunOffset longestRunLength = currentRunLength } i += 2 } } // Emit each 2-byte group in hex, separated by ':'. The longest run of zeroes is "::". val result = Buffer() var i = 0 while (i < address.size) { if (i == longestRunOffset) { result.writeByte(':'.code)
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0)