Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 806 for emit (0.04 sec)

  1. 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,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. 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
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. 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()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. common-protos/k8s.io/api/networking/v1beta1/generated.proto

      // resource. This replaces the deprecated `kubernetes.io/ingress.class`
      // annotation. For backwards compatibility, when that annotation is set, it
      // must be given precedence over this field. The controller may emit a
      // warning if the field and annotation have different values.
      // Implementations of this API should ignore Ingresses without a class
      // specified. An IngressClass resource may be marked as default, which can
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  7. 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)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  8. 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:
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
  9. istioctl/pkg/analyze/analyze.go

    				parts := strings.Split(s, "=")
    				if len(parts) != 2 {
    					return fmt.Errorf("%s is not a valid suppression value. See istioctl analyze --help", s)
    				}
    				// Check to see if the supplied code is valid. If not, emit a
    				// warning but continue.
    				codeIsValid := false
    				for _, at := range msg.All() {
    					if at.Code() == parts[0] {
    						codeIsValid = true
    						break
    					}
    				}
    
    				if !codeIsValid {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 31 06:53:50 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  10. 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()...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat May 28 04:16:16 UTC 2022
    - 10.5K bytes
    - Viewed (0)
Back to top