Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for Cramer (0.26 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

            if (closed) return
            outFinished = errorCode == null
          }
          if (!sink.finished) {
            // We have 0 or more frames of data, and 0 or more frames of trailers. We need to send at
            // least one frame with the END_STREAM flag set. That must be the last frame, and the
            // trailers must be sent after all of the data.
            val hasData = sendBuffer.size > 0L
            val hasTrailers = trailers != null
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      ): Boolean {
        // Don't send new frames after we've failed or enqueued a close frame.
        if (failed || enqueuedClose) return false
    
        // If this frame overflows the buffer, reject it and close the web socket.
        if (queueSize + data.size > MAX_QUEUE_SIZE) {
          close(CLOSE_CLIENT_GOING_AWAY, null)
          return false
        }
    
        // Enqueue the message frame.
        queueSize += data.size.toLong()
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        // Note: we don't process server frames so our client 'close' doesn't receive a server 'close'.
        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(4_999))
        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(5_000))
        assertThat(client.canceled).isTrue()
    
        client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Thu Apr 11 01:59:58 GMT 2024
    - 18.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

      /**
       * HTTP/2 only. Send a push promise header block.
       *
       * A push promise contains all the headers that pertain to a server-initiated request, and a
       * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as
       * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
       * `streamId`.
       *
       * @param streamId client-initiated stream ID.  Must be an odd number.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        close(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, e)
      }
    
      /**
       * Sends any initial frames and starts reading frames from the remote peer. This should be called
       * after [Builder.build] for all new connections.
       *
       * @param sendConnectionPreface true to send connection preface frames. This should always be true
       *     except for in tests that don't check for a connection preface.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  6. schema/relationship.go

    		Tag:  `gorm:"-"`,
    	})
    
    	if relation.JoinTable, err = Parse(reflect.New(reflect.StructOf(joinTableFields)).Interface(), schema.cacheStore,
    		schema.namer); err != nil {
    		schema.err = err
    	}
    	relation.JoinTable.Name = many2many
    	relation.JoinTable.Table = schema.namer.JoinTableName(many2many)
    	relation.JoinTable.PrimaryFields = make([]*Field, 0, len(relation.JoinTable.Fields))
    
    	relName := relation.Schema.Name
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Mon Apr 15 03:20:20 GMT 2024
    - 22.4K bytes
    - Viewed (0)
  7. docs/en/data/github_sponsors.yml

      - login: yasyf
        avatarUrl: https://avatars.githubusercontent.com/u/709645?u=f36736b3c6a85f578886ecc42a740e7b436e7a01&v=4
        url: https://github.com/yasyf
    - - login: primer-io
        avatarUrl: https://avatars.githubusercontent.com/u/62146168?v=4
        url: https://github.com/primer-io
      - login: povilasb
        avatarUrl: https://avatars.githubusercontent.com/u/1213442?u=b11f58ed6ceea6e8297c9b310030478ebdac894d&v=4
        url: https://github.com/povilasb
    Others
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Mon Apr 01 23:12:23 GMT 2024
    - 26.4K bytes
    - Viewed (0)
  8. schema/field.go

    			field.Readable = false
    
    			cacheStore := &sync.Map{}
    			cacheStore.Store(embeddedCacheKey, true)
    			if field.EmbeddedSchema, err = getOrParse(fieldValue.Interface(), cacheStore, embeddedNamer{Table: schema.Table, Namer: schema.namer}); err != nil {
    				schema.err = err
    			}
    
    			for _, ef := range field.EmbeddedSchema.Fields {
    				ef.Schema = schema
    				ef.OwnerSchema = field.EmbeddedSchema
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Mon Apr 15 03:20:20 GMT 2024
    - 32K bytes
    - Viewed (1)
  9. docs/es/docs/tutorial/first-steps.md

    ```
    
    </div>
    
    ### Paso 3: crea una *operación de path*
    
    #### Path
    
    "Path" aquí se refiere a la última parte de una URL comenzando desde el primer `/`.
    
    Entonces, en una URL como:
    
    ```
    https://example.com/items/foo
    ```
    
    ...el path sería:
    
    ```
    /items/foo
    ```
    
    !!! info "Información"
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  10. istioctl/pkg/precheck/precheck.go

    		return err
    	}
    	if err != nil {
    		// not found
    		return nil
    	}
    	// found
    	res := ObjectToInstance(svc)
    	messages.Add(msg.NewUpdateIncompatibility(res,
    		"meshConfig.defaultConfig.tracer", "1.21",
    		"tracing is no longer by default enabled to send to 'zipkin.istio-system.svc'; "+
    			"follow https://istio.io/latest/docs/tasks/observability/distributed-tracing/telemetry-api/",
    		"1.21"))
    	return nil
    }
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 12 02:57:30 GMT 2024
    - 19.3K bytes
    - Viewed (0)
Back to top