- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for IsStream (0.14 sec)
-
internal/grid/stream.go
// If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_internal.h
SP_Event event_handle_; }; class CStream : public StreamCommon { public: CStream(SP_Device* device, SP_StreamExecutor* stream_executor, StreamExecutor* executor) : StreamCommon(executor), device_(device), stream_executor_(stream_executor), stream_handle_(nullptr) {} ~CStream() override { parent()->BlockHostUntilDone(this).IgnoreError();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 8K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Node.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 3.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java
import java.util.Comparator; import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import java.util.function.Supplier; import java.util.stream.Collectors; import com.google.inject.AbstractModule; import com.google.inject.binder.AnnotatedBindingBuilder; import com.google.inject.name.Names; import org.apache.maven.api.di.MojoExecutionScoped;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 8.8K bytes - Viewed (0) -
subprojects/diagnostics/src/main/java/org/gradle/api/reporting/dependencies/HtmlDependencyReportTask.java
import org.gradle.internal.logging.ConsoleRenderer; import org.gradle.internal.serialization.Cached; import org.gradle.util.internal.ClosureBackedAction; import javax.inject.Inject; import java.util.stream.Stream; /** * Generates an HTML dependency report. This report * combines the features of the ASCII dependency report and those of the ASCII
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 13:33:20 UTC 2024 - 6.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/PluginResolutionException.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.plugin; import java.util.List; import java.util.stream.Collectors; import org.apache.maven.model.Plugin; /** * Exception occurring trying to resolve a plugin. * */ public class PluginResolutionException extends Exception {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jun 12 07:49:10 UTC 2024 - 2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/session/scope/internal/SessionScope.java
import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.function.Supplier; import java.util.stream.Collectors; import java.util.stream.Stream; import com.google.inject.Key; import com.google.inject.OutOfScopeException; import com.google.inject.Provider; import com.google.inject.Scope; import com.google.inject.name.Names; /**
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 7.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/CurrentProcess.java
import org.gradle.internal.instrumentation.agent.AgentUtils; import org.gradle.internal.jvm.JavaInfo; import org.gradle.internal.jvm.Jvm; import java.lang.management.ManagementFactory; import java.util.List; import java.util.stream.Collectors; public class CurrentProcess { private final JavaInfo jvm; private final JvmOptions effectiveJvmOptions; public CurrentProcess(FileCollectionFactory fileCollectionFactory) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 2.6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultDependencyResolver.java
import java.nio.file.Path; import java.util.Collection; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.Set; import java.util.function.Predicate; import java.util.stream.Collectors; import org.apache.maven.api.*; import org.apache.maven.api.Artifact; import org.apache.maven.api.ArtifactCoordinate; import org.apache.maven.api.Dependency; import org.apache.maven.api.Node;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 8.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/conflicts/ConflictContainer.java
return conflicts.isEmpty(); } boolean hasMatchingConflict(Predicate<T> predicate) { if (isEmpty()) { return false; } return conflicts.stream().flatMap(conflict -> conflict.candidates.stream()).anyMatch(predicate); } class Conflict { final Set<K> participants; Collection<? extends T> candidates;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 5.5K bytes - Viewed (0)