Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 26 for closer (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/metrics-v2.go

    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    func metricsBucketHandler() http.Handler {
    	return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket")
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/cache/LocalCache.java

        public LoadingValueReference() {
          this(LocalCache.<K, V>unset());
        }
    
        /*
         * TODO(cpovirk): Consider making this implementation closer to the mainline implementation.
         * (The difference was introduced as part of Java-8-specific changes in cl/132882204, but we
         * could probably make *some* of those changes here in the backport, too.)
         */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      `Tut, tut, child!' said the Duchess.  `Everything's got a
    moral, if only you can find it.'  And she squeezed herself up
    closer to Alice's side as she spoke.
    
      Alice did not much like keeping so close to her:  first,
    because the Duchess was VERY ugly; and secondly, because she was
    exactly the right height to rest her chin upon Alice's shoulder,
    and it was an uncomfortably sharp chin.  However, she did not
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Oct 29 21:35:03 GMT 2012
    - 145.2K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

          .assertFailure("canceled", "Canceled", "Socket closed", "Socket is closed")
      }
    
      @Test
      fun cancelAll() {
        val call = client.newCall(Request(server.url("/")))
        call.enqueue(callback)
        client.dispatcher.cancelAll()
        callback
          .await(server.url("/"))
          .assertFailure("canceled", "Canceled", "Socket closed", "Socket is closed")
      }
    
      @Test
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

       * characters can be read, the remaining characters are returned and the stream is closed.
       */
      private fun readAscii(
        inputStream: InputStream,
        count: Int,
      ): String {
        val result = StringBuilder()
        for (i in 0 until count) {
          val value = inputStream.read()
          if (value == -1) {
            inputStream.close()
            break
          }
          result.append(value.toChar())
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbFile.java

                }
    
                final Smb2CloseRequest closeReq = new Smb2CloseRequest(th.getConfig(), Smb2Constants.UNSPECIFIED_FILEID);
                closeReq.setCloseFlags(Smb2CloseResponse.SMB2_CLOSE_FLAG_POSTQUERY_ATTIB);
                cur.chain(closeReq);
    
                final Smb2CreateResponse createResp = th.send(cr);
    
                final Smb2CloseResponse closeResp = closeReq.getResponse();
                SmbBasicFileInfo info;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 103.2K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/smb1/SmbFile.java

        }
    
        void close(final int f, final long lastWriteTime) throws SmbException {
    
            if (LogStream.level >= 3) {
                log.println("close: " + f);
            }
    
            /*
             * Close Request / Response
             */
    
            send(new SmbComClose(f, lastWriteTime), blank_resp());
        }
    
        void close(final long lastWriteTime) throws SmbException {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 112.2K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        response.body.string()
        val cached = cacheGet(cache, request)
        if (shouldWriteToCache) {
          assertThat(cached).isNotNull()
          cached!!.body.close()
        } else {
          assertThat(cached).isNull()
        }
        server.close() // tearDown() isn't sufficient; this test starts multiple servers
      }
    
      private fun assertSubsequentResponseCached(
        initialResponseCode: Int,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 121K bytes
    - Click Count (0)
  9. src/main/webapp/js/admin/adminlte.min.js.map

    is._config.title))\n    }\n\n    if (this._config.subtitle != null) {\n      toastHeader.append($('<small />').html(this._config.subtitle))\n    }\n\n    if (this._config.close == true) {\n      const toastClose = $('<button data-dismiss=\"toast\" />').attr('type', 'button').addClass('ml-2 mb-1 close').attr('aria-label', 'Close').append('<span aria-hidden=\"true\">&times;</span>')\n\n      if (this._config.title == null) {\n        toastClose.toggleClass('ml-2 ml-auto')\n      }\n\n      toastHe...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 132.4K bytes
    - Click Count (0)
  10. okhttp/src/androidMain/baseline-prof.txt

    HSPLokio/ForwardingSink;-><init>(Lokio/Sink;)V
    HSPLokio/ForwardingSink;->close()V
    HSPLokio/ForwardingSink;->write(Lokio/Buffer;J)V
    HSPLokio/ForwardingSource;-><init>(Lokio/Source;)V
    HSPLokio/ForwardingSource;->close()V
    HSPLokio/GzipSource;-><init>(Lokio/Source;)V
    HSPLokio/GzipSource;->checkEqual(Ljava/lang/String;II)V
    HSPLokio/GzipSource;->close()V
    HSPLokio/GzipSource;->read(Lokio/Buffer;J)J
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 127.9K bytes
    - Click Count (1)
Back to Top