Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 1,049 for closes (0.03 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/kt/UploadProgress.kt

        }
      }
    
      private class ProgressRequestBody(
        private val delegate: RequestBody,
        private val progressListener: ProgressListener,
      ) : RequestBody() {
        override fun contentType() = delegate.contentType()
    
        @Throws(IOException::class)
        override fun contentLength(): Long = delegate.contentLength()
    
        @Throws(IOException::class)
        override fun writeTo(sink: BufferedSink) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  2. cmd/signals.go

    	finished := make(chan struct{})
    	go func() {
    		globalMRFState.shutdown()
    		close(finished)
    	}()
    	select {
    	case <-time.After(shutdownTimeout):
    	case <-finished:
    	}
    }
    
    func handleSignals() {
    	// Custom exit function
    	exit := func(success bool) {
    		if globalLoggerOutput != nil {
    			globalLoggerOutput.Close()
    		}
    
    		// If global profiler is set stop before we exit.
    		globalProfilerMu.Lock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt

            else -> "Failure[$response]"
          }
      }
    
      internal data class Message(
        val bytes: ByteString? = null,
        val string: String? = null,
      )
    
      internal data class Ping(
        val payload: ByteString,
      )
    
      internal data class Pong(
        val payload: ByteString,
      )
    
      internal data class Closing(
        val code: Int,
        val reason: String,
      )
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/lex/stack.go

    func (s *Stack) Push(tr TokenReader) {
    	s.tr = append(s.tr, tr)
    }
    
    func (s *Stack) Next() ScanToken {
    	tos := s.tr[len(s.tr)-1]
    	tok := tos.Next()
    	for tok == scanner.EOF && len(s.tr) > 1 {
    		tos.Close()
    		// Pop the topmost item from the stack and resume with the next one down.
    		s.tr = s.tr[:len(s.tr)-1]
    		tok = s.Next()
    	}
    	return tok
    }
    
    func (s *Stack) Text() string {
    	return s.tr[len(s.tr)-1].Text()
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Jan 09 22:33:23 UTC 2017
    - 1.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CharSourceTester.java

        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertExpectedString(writer.toString());
      }
    
      public void testOpenBufferedStream() throws IOException {
        BufferedReader reader = source.openBufferedStream();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/suggest/index/contents/querylog/QueryLogReader.java

     * It extends the {@code Closeable} interface, ensuring that resources can be released when no longer needed.
     */
    public interface QueryLogReader extends Closeable {
        /**
         * Reads a query log.
         * @return The query log.
         */
        QueryLog read();
    
        @Override
        void close();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java

          StringWriter target = new StringWriter(2 * n);
          OutputStream encodingStream = encoding.encoding.encodingStream(target);
          encodingStream.write(encodingInputs[i & INPUTS_MASK]);
          encodingStream.close();
          tmp += target.getBuffer().length();
        }
        return tmp;
      }
    
      @Benchmark
      public int decodingStream(int reps) throws IOException {
        int tmp = 0;
        byte[] target = new byte[n];
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. src/main/webapp/js/bootstrap.min.js.map

    */\n\nconst NAME = 'alert'\nconst DATA_KEY = 'bs.alert'\nconst EVENT_KEY = `.${DATA_KEY}`\n\nconst EVENT_CLOSE = `close${EVENT_KEY}`\nconst EVENT_CLOSED = `closed${EVENT_KEY}`\nconst CLASS_NAME_FADE = 'fade'\nconst CLASS_NAME_SHOW = 'show'\n\n/**\n * Class definition\n */\n\nclass Alert extends BaseComponent {\n  // Getters\n  static get NAME() {\n    return NAME\n  }\n\n  // Public\n  close() {\n    const closeEvent = EventHandler.trigger(this._element, EVENT_CLOSE)\n\n    if (closeEvent.defaultPrevented)...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 12 06:14:02 UTC 2025
    - 211.9K bytes
    - Viewed (0)
  9. src/main/java/jcifs/SmbSession.java

     *
     * @author mbechler
     */
    public interface SmbSession extends AutoCloseable {
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        void close();
    
        /**
         * Returns the configuration object used by this SMB session.
         *
         * @return the configuration used by this session
         */
        Configuration getConfig();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

            .isEqualTo("response D")
          requestBody.writeUtf8("request E\n")
          requestBody.flush()
          assertThat(responseBody.readUtf8Line())
            .isEqualTo("response F")
          requestBody.close()
          assertThat(responseBody.readUtf8Line()).isNull()
        }
        body.awaitSuccess()
      }
    
      @Test
      fun trueDuplexServerWritesFirst() {
        enableProtocol(Protocol.HTTP_2)
        val body =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
Back to top