Search Options

Results per page
Sort
Preferred Languages
Advance

Results 551 - 560 of 835 for streams (0.04 sec)

  1. tensorflow/c/c_api_macros_internal.h

    // `struct_size` is used for struct member compatibility check between core TF
    // and plug-ins with the same C API minor version. More info here:
    // https://github.com/tensorflow/community/blob/master/rfcs/20200612-stream-executor-c-api/C_API_versioning_strategy.md
    #define TF_VALIDATE_STRUCT_SIZE(STRUCT_NAME, STRUCT_OBJ, SIZE_VALUE_NAME) \
      do {                                                                    \
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Mar 13 17:40:56 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.logging.Level;
    import java.util.logging.Logger;
    import java.util.regex.MatchResult;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Stream;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing
     * utilities.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/Optional.java

       * <p><b>Comparison to {@code java.util.Optional}:</b> this method has no equivalent in Java 8's
       * {@code Optional} class; use {@code
       * optionals.stream().filter(Optional::isPresent).map(Optional::get)} instead.
       *
       * <p><b>Java 9 users:</b> use {@code optionals.stream().flatMap(Optional::stream)} instead.
       *
       * @since 11.0 (generics widened in 13.0)
       */
      public static <T> Iterable<T> presentInstances(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/config/exentity/DataConfig.java

    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Properties;
    import java.util.function.Supplier;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.http.auth.AuthScheme;
    import org.apache.http.auth.AuthScope;
    import org.apache.http.auth.Credentials;
    import org.apache.http.auth.NTCredentials;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:15 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/SearchHelper.java

    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ExecutionException;
    import java.util.function.Consumer;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.exception.InterruptedRuntimeException;
    import org.codelibs.core.lang.StringUtil;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/ImmutableEnumMap.java

      @Override
      @J2ktIncompatible // serialization
      Object writeReplace() {
        return new EnumSerializedForm<>(delegate);
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use EnumSerializedForm");
      }
    
      /*
       * This class is used to serialize ImmutableEnumMap instances.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. compat/maven-model/src/test/java/org/apache/maven/model/v4/ModelXmlTest.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.model.v4;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.util.LinkedHashMap;
    import java.util.Map;
    
    import org.apache.maven.api.model.Model;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsWriter.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.settings.io;
    
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.OutputStream;
    import java.io.Writer;
    import java.nio.file.Files;
    import java.util.Map;
    import java.util.Objects;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/util/InputStreamThread.java

                        }
                    }
                } catch (final Exception e) {
                    running = false;
                    if (logger.isDebugEnabled()) {
                        logger.debug("Failed to process an input stream.", e);
                    }
                }
            }
        }
    
        public String getOutput() {
            final StringBuilder buf = new StringBuilder(100);
            for (final String value : list) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/-ResponseBodyCommon.kt

      }
    
      val bytes = source().use(consumer)
      val size = sizeMapper(bytes)
      if (contentLength != -1L && contentLength != size.toLong()) {
        throw IOException("Content-Length ($contentLength) and stream length ($size) disagree")
      }
      return bytes
    }
    
    internal fun ResponseBody.commonClose() = source().closeQuietly()
    
    internal fun ByteArray.commonToResponseBody(contentType: MediaType?): ResponseBody {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top