Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 34 for closer (0.04 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *
     * {@snippet :
     * FluentFuture<UserName> userName =
     *     ClosingFuture.submit(
     *             closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
     *             executor)
     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
     *         .transform((closer, result) -> result.get("userName"), directExecutor())
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. android/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: Fri Apr 21 02:27:51 GMT 2017
    - 145.2K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/admin-handlers.go

    		if err != nil {
    			bugLogIf(ctx, stream.AddError(err.Error()))
    			return
    		}
    		addErr = func(msg string) {
    			inspectZipW.Close()
    			encStream.Close()
    			stream.AddError(msg)
    		}
    		defer encStream.Close()
    
    		inspectZipW = zip.NewWriter(encStream)
    		defer inspectZipW.Close()
    	} else {
    		// Legacy: Remove if we stop supporting inspection without public key.
    		var key [32]byte
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
Back to Top