Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for Promise (0.17 sec)

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

            flags = FLAG_ACK,
          )
          sink.flush()
        }
      }
    
      /**
       * 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
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          weight: Int,
          exclusive: Boolean,
        )
    
        /**
         * HTTP/2 only. Receive 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`.
         *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

            Header(Header.TARGET_PATH, "/"),
          )
    
        // Write the push promise frame, specifying the associated stream ID.
        val headerBytes = literalHeaders(pushPromise)
        writeMedium(frame, (headerBytes.size + 4).toInt())
        frame.writeByte(Http2.TYPE_PUSH_PROMISE)
        frame.writeByte(Http2.FLAG_END_PUSH_PROMISE)
        frame.writeInt(expectedStreamId and 0x7fffffff)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 28.1K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

        /**
         * When [protocols][MockWebServer.protocols] include [HTTP_2][okhttp3.Protocol], this attaches a
         * pushed stream to this response.
         */
        fun addPush(promise: PushPromise) =
          apply {
            this.pushPromises += promise
          }
    
        /**
         * When [protocols][MockWebServer.protocols] include [HTTP_2][okhttp3.Protocol], this pushes
         * [settings] before writing the response.
         */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 13.3K bytes
    - Viewed (1)
  5. android/guava/src/com/google/common/collect/ImmutableCollection.java

           * we're copying into a `contents` array whose type allows it to contain nulls. Still, it's
           * worth noting that we promise not to put nulls into the array in the first `size` elements.
           * We uphold that promise here because our callers promise that `elements` will not contain
           * nulls in its first `n` elements.
           */
          System.arraycopy(elements, 0, contents, size, n);
          size += n;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 21.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/ImmutableList.java

           * we're copying into a `contents` array whose type allows it to contain nulls. Still, it's
           * worth noting that we promise not to put nulls into the array in the first `size` elements.
           * We uphold that promise here because our callers promise that `elements` will not contain
           * nulls in its first `n` elements.
           */
          System.arraycopy(elements, 0, contents, size, n);
          size += n;
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 30K bytes
    - Viewed (1)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      private val writerQueue = taskRunner.newQueue()
    
      /** Ensures push promise callbacks events are sent in order per stream. */
      private val pushQueue = taskRunner.newQueue()
    
      /** Notifies the listener of settings changes. */
      private val settingsListenerQueue = taskRunner.newQueue()
    
      /** User code to run in response to push promise events. */
      private val pushObserver: PushObserver = builder.pushObserver
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

                // callable actually completes. (We could detect completion in our wrapper
                // `AsyncCallable task`.) However, our contract also promises:
                //
                // 2. not to cancel any Future the user returned from an AsyncCallable
                //
                // We promise this because, once we cancel that Future, we would no longer be able to
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  9. tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc

      }
    }
    
    static int GetChildren(const TF_Filesystem* filesystem, const char* path,
                           char*** entries, TF_Status* status) {
      struct dirent** dir_entries = nullptr;
      /* we don't promise entries would be sorted */
      int num_entries =
          scandir(path, &dir_entries, RemoveSpecialDirectoryEntries, nullptr);
      if (num_entries < 0) {
        TF_SetStatusFromIOError(status, errno, path);
      } else {
    C++
    - Registered: Tue Apr 23 12:39:09 GMT 2024
    - Last Modified: Sun Mar 24 20:08:23 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  10. misc/wasm/wasm_exec.js

    		constructor() {
    			this.argv = ["js"];
    			this.env = {};
    			this.exit = (code) => {
    				if (code !== 0) {
    					console.warn("exit code:", code);
    				}
    			};
    			this._exitPromise = new Promise((resolve) => {
    				this._resolveExitPromise = resolve;
    			});
    			this._pendingEvent = null;
    			this._scheduledTimeouts = new Map();
    			this._nextCallbackTimeoutID = 1;
    
    			const setInt64 = (addr, v) => {
    JavaScript
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon May 22 17:47:47 GMT 2023
    - 16.3K bytes
    - Viewed (1)
Back to top