Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 581 - 590 of 1,261 for Stream (0.25 seconds)

  1. docs/zh-hant/docs/advanced/custom-response.md

    因為這個小範例不需要任何 `await` 陳述式,我們加入 `await anyio.sleep(0)`,讓事件迴圈有機會處理取消。
    
    對於大型或無限的串流來說,這點更為重要。
    
    ///
    
    /// tip
    
    與其直接回傳 `StreamingResponse`,你大概會想遵循[資料串流](./stream-data.md)中的作法,這樣更方便,並且會在底層幫你處理取消。
    
    如果你要串流 JSON Lines,請參考教學:[串流 JSON Lines](../tutorial/stream-json-lines.md)。
    
    ///
    
    ### `FileResponse` { #fileresponse }
    
    以非同步串流方式將檔案作為回應。
    
    它在初始化時所需的參數與其他回應型別不同:
    
    - `path` - 要串流的檔案路徑。
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/AbstractBiMap.java

            private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(inverse());
        }
    
        @GwtIncompatible
        @J2ktIncompatible
            @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
          stream.defaultReadObject();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  3. src/test/java/jcifs/smb/ShareEnumIteratorTest.java

    import static org.mockito.Mockito.when;
    
    import java.net.MalformedURLException;
    import java.util.Arrays;
    import java.util.Collections;
    import java.util.Iterator;
    import java.util.List;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/MIENameTest.java

    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    
    import java.nio.charset.StandardCharsets;
    import java.util.stream.Stream;
    
    import org.bouncycastle.asn1.ASN1ObjectIdentifier;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

          b.append(longBitsToDouble(longs.get(i)));
          if (i == iMax) {
            return b.append(']').toString();
          }
          b.append(',').append(' ');
        }
      }
    
      /**
       * Saves the state to a stream (that is, serializes it).
       *
       * @serialData The length of the array is emitted (int), followed by all of its elements (each a
       *     {@code double}) in the proper order.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java

                });
            });
        }
    
        /**
         * Download the stemmer override dictionary file.
         * Streams the dictionary file as an octet-stream download.
         *
         * @param form The download form containing dictionary ID
         * @return Action response with file stream for download
         */
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public ActionResponse download(final DownloadForm form) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 23.5K bytes
    - Click Count (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/FindBadMultiLangSnippets.java

            );
    
        private void gatherBadSnippetsInFile(File file, Map<File, List<Error>> errors) {
            List<String> lines = new ArrayList<>();
            try (java.util.stream.Stream<String> stream = Files.lines(file.toPath())) {
                stream.forEach(lines::add);
            } catch (IOException ex) {
                // If a file can't be read, add an error
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Aug 29 10:12:17 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/execution/ProjectActivation.java

    package org.apache.maven.execution;
    
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.Set;
    import java.util.function.Predicate;
    import java.util.stream.Stream;
    
    import static java.util.stream.Collectors.toSet;
    
    /**
     * Container for storing the request from the user to activate or deactivate certain projects and optionally fail the
     * build if those projects do not exist.
     */
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 11 16:38:19 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  9. .teamcity/scripts/CheckBadMerge.java

            boolean p2IsMaster = p2Branches.contains("origin/master");
            boolean p2IsRelease = p2Branches.stream().anyMatch(b -> b.startsWith("origin/release"));
    
            if (p1IsMaster && !p2IsMaster && p2IsRelease) {
                List<String> badFiles = filesFromMerge(commit).stream()
                    .filter(gitFile -> MONITORED_PATHS.stream().anyMatch(forbiddenPath -> gitFile.startsWith(forbiddenPath)))
                    .collect(Collectors.toList());
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 30 16:25:09 GMT 2026
    - 9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java

                    postcard.setFrom(fessConfig.getMailFromAddress(), fessConfig.getMailFromName());
                    postcard.addReplyTo(fessConfig.getMailReturnPath());
                    stream(toAddresses).of(stream -> stream.forEach(address -> {
                        postcard.addTo(address);
                    }));
                    BeanUtil.copyMapToBean(dataMap, postcard);
                });
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 05:54:31 GMT 2026
    - 27.2K bytes
    - Click Count (0)
Back to Top