Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 2,033 for STREAM (0.12 sec)

  1. api/maven-api-core/src/main/java/org/apache/maven/api/Node.java

         */
        @Nonnull
        String asString();
    
        /**
         * Obtain a Stream containing this node and all its descendant.
         *
         * @return a stream containing this node and its descendant
         */
        @Nonnull
        default Stream<Node> stream() {
            return Stream.concat(Stream.of(this), getChildren().stream().flatMap(Node::stream));
        }
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Jun 11 07:23:04 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. tensorflow/c/experimental/stream_executor/stream_executor.cc

                                               &HostCallbackTrampoline, ctx);
      }
      void DeallocateStream(Stream* stream) override {
        static_cast<CStream*>(stream)->Destroy();
      }
      absl::Status BlockHostForEvent(Stream* stream, Event* event) {
        OwnedTFStatus c_status(TF_NewStatus());
        SP_Event event_handle = static_cast<CEvent*>(event)->Handle();
        stream_executor_->block_host_for_event(&device_, event_handle,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri Jun 14 07:39:19 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  3. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/ServiceLocatorTest.groovy

            def serviceLocator = new DefaultServiceLocator(classLoader, classLoader2)
    
            def serviceFile1 = stream('org.gradle.ImplClass')
            def serviceFile2 = stream('org.gradle.ImplClass2')
            def serviceFile3 = stream('org.gradle.ImplClass')
            def serviceFile4 = stream('org.gradle.ImplClass3')
    
            when:
            def result = serviceLocator.getAll(CharSequence.class)
    
            then:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  4. api/maven-api-core/src/main/java/org/apache/maven/api/services/LifecycleRegistry.java

     */
    package org.apache.maven.api.services;
    
    import java.util.stream.Stream;
    import java.util.stream.StreamSupport;
    
    import org.apache.maven.api.Lifecycle;
    
    public interface LifecycleRegistry extends ExtensibleEnumRegistry<Lifecycle>, Iterable<Lifecycle> {
    
        default Stream<Lifecycle> stream() {
            return StreamSupport.stream(spliterator(), false);
        }
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed May 22 13:45:13 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        }
      }
    
      /**
       * Returns true if this stream is open. A stream is open until either:
       *
       *  * A `SYN_RESET` frame abnormally terminates the stream.
       *  * Both input and output streams have transmitted all data and headers.
       *
       * Note that the input stream may continue to yield data even after a stream reports itself as
       * not open. This is because input data is buffered.
       */
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

     */
    package org.codelibs.fess.app.service;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.io.IOException;
    import java.io.Reader;
    import java.io.Writer;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import javax.annotation.Resource;
    
    import org.apache.logging.log4j.LogManager;
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  7. tensorflow/compiler/jit/xla_device.cc

                                           bool* stream_was_changed) {
      if (!(*stream) || !(*stream)->ok()) {
        xla::StreamPool::Ptr ptr;
        TF_ASSIGN_OR_RETURN(ptr, backend->BorrowStream(device_ordinal_));
        *stream = std::shared_ptr<se::Stream>(std::move(ptr));
        VLOG(1) << "XlaDevice " << this << " new " << name
                << " stream=" << (*stream);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon May 20 21:05:42 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  8. api/maven-api-model/src/main/java/org/apache/maven/api/model/InputSource.java

        @Override
        public int hashCode() {
            return Objects.hash(modelId, location, inputs);
        }
    
        Stream<InputSource> sources() {
            return inputs != null ? inputs.stream() : Stream.of(this);
        }
    
        @Override
        public String toString() {
            if (inputs != null) {
                return inputs.stream().map(InputSource::toString).collect(Collectors.joining(", ", "merged[", "]"));
            }
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Sep 05 16:06:44 UTC 2023
    - 3K bytes
    - Viewed (0)
  9. platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/test/impl/DefaultTestTaskProperties.java

            return forkOptions;
        }
    
        @Override
        public Stream<CandidateClassFile> getCandidateClassFiles() {
            return candidateClassFiles.stream();
        }
    
        @Override
        public Stream<InputFileProperty> getInputFileProperties() {
            return inputFileProperties.stream();
        }
    
        @Override
        public Stream<OutputFileProperty> getOutputFileProperties() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 26 14:58:23 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                                }
                            });
                            final List<String> newGroupList = stream(user.getGroupNames()).get(stream -> stream.collect(Collectors.toList()));
                            stream(user.getGroupNames()).of(stream -> stream.forEach(name -> {
                                if (oldGroupList.contains(name)) {
                                    oldGroupList.remove(name);
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 65.9K bytes
    - Viewed (0)
Back to top