Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for home (0.31 sec)

  1. docs/bucket/notifications/README.md

    auto_deleted   (on|off)    auto delete queue when set to 'on', when there are no consumers
    delivery_mode  (number)    set to '1' for non-persistent or '2' for persistent queue
    queue_dir      (path)      staging dir for undelivered messages e.g. '/home/events'
    queue_limit    (number)    maximum limit for undelivered messages, defaults to '100000'
    comment        (sentence)  optionally add a comment to this setting
    ```
    
    Or environment variables
    
    ```
    KEY:
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  2. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        // Create an editor, then detach it.
        val editor = cache.edit("k1")!!
        editor.newSink(0).buffer().use { sink ->
          cache.evictAll()
    
          // Complete the original edit. It goes into a black hole.
          sink.writeUtf8("bb")
        }
        assertThat(cache["k1"]).isNull()
      }
    
      @ParameterizedTest
      @ArgumentsSource(FileSystemParamProvider::class)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 75.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

          checkNotNull(certificateChainCleaner) { "certificateChainCleaner == null" }
          checkNotNull(x509TrustManager) { "x509TrustManager == null" }
        }
      }
    
      /** Prepares the [request] to be executed at some point in the future. */
      override fun newCall(request: Request): Call = RealCall(this, request, forWebSocket = false)
    
      /** Uses [request] to connect a new web socket. */
      override fun newWebSocket(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:21:33 GMT 2024
    - 52K bytes
    - Viewed (0)
  4. .bazelrc

    # errors.
    # There is ongoing work on Bazel team's side to provide support for transitive
    # shared libraries. As part of migrating to transitive shared libraries, we
    # hope to provide a better mechanism for control over symbol exporting, and
    # then tackle this issue again.
    #
    # TODO: Remove the following two lines once TF doesn't depend on Bazel wrapping
    Plain Text
    - Registered: Tue May 07 12:40:20 GMT 2024
    - Last Modified: Thu May 02 19:34:20 GMT 2024
    - 52.8K bytes
    - Viewed (2)
  5. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirReferenceShortener.kt

        }
    
        /**
         * Retrieves the corresponding [KtUserType] PSI the given [FirResolvedTypeRef].
         *
         * This code handles some quirks of FIR sources and PSI:
         * - in `vararg args: String` declaration, `String` type reference has fake source, but `Array<String>` has real source
         * (see [KtFakeSourceElementKind.ArrayTypeFromVarargParameter]).
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Thu Apr 25 18:51:33 GMT 2024
    - 69.5K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(synStream.type).isEqualTo(Http2.TYPE_HEADERS)
        val ping = peer.takeFrame()
        assertThat(ping.type).isEqualTo(Http2.TYPE_PING)
      }
    
      @Test fun serverWritesTrailersWithData() {
        // We buffer some outbound data and headers and confirm that the END_STREAM flag comes with the
        // headers (and not with the data).
    
        // Write the mocking script. for the client
        peer.setClient(true)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 75.4K bytes
    - Viewed (0)
Back to top