- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,928 for STREAM (0.14 sec)
-
subprojects/core/src/main/java/org/gradle/internal/fingerprint/impl/FileCollectionFingerprinterRegistrations.java
); } private static <T> Stream<T> withAllLineEndingSensitivities(Function<LineEndingSensitivity, Stream<T>> f) { return stream(LineEndingSensitivity.values()).flatMap(f); } private static <T> Stream<T> withAllDirectorySensitivities(Function<DirectorySensitivity, Stream<T>> f) { return stream(DirectorySensitivity.values()).flatMap(f); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 29 16:58:45 UTC 2022 - 8.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
writeBytesTotal >= writeBytesMaximum || stream.writeBytesTotal >= stream.writeBytesMaximum if (stream.isOpen) { streams[streamId] = stream } } if (associatedStreamId == 0) { writer.headers(outFinished, streamId, requestHeaders) } else { require(!client) { "client streams shouldn't have associated stream IDs" } // HTTP/2 has a PUSH_PROMISE frame.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_context.cc
} return stream_executor_->ClearAllocatorStats(); } XlaDeviceContext::XlaDeviceContext( std::shared_ptr<se::Stream> compute_stream, std::shared_ptr<se::Stream> host_to_device_stream, std::shared_ptr<se::Stream> device_to_host_stream, std::vector<std::shared_ptr<se::Stream>> device_to_device_streams, xla::LocalClient* client, XlaShapeLayoutHelpers::ShapeDeterminationFns shape_determination_fns,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 16 00:36:08 UTC 2024 - 12.7K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_recv_device_context.h
// // Device device; // stream_executor::Stream stream(executor); // Tensor device_tensor(device_allocator, DT_FLOAT, TensorShape({2, 2})); // se::DeviceMemoryBase gpu_dst{device_tensor.data(), 4 * sizeof(float)}; // xla::Shape shape(xla::F32, {2, 2}, {}, {}) // tsl::AsyncValueRef<std::unique_ptr<se::Event>> done_event = // tsl::MakeConstructedAsyncValueRef<std::unique_ptr<se::Event>>(stream.parent()); // done_event->Init();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 3.9K 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) -
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) -
src/main/java/org/codelibs/fess/helper/ActivityHelper.java
*/ package org.codelibs.fess.helper; import static org.codelibs.core.stream.StreamUtil.stream; import java.time.ZonedDateTime; import java.time.format.DateTimeFormatter; import java.util.Comparator; import java.util.LinkedHashMap; import java.util.Locale; import java.util.Map; import java.util.stream.Collectors; import javax.annotation.PostConstruct;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.7K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/history/changes/PropertyChanges.java
return true; } Stream<DescriptiveChange> removedProperties = Sets.difference(previous, current).stream() .map(removedProperty -> new DescriptiveChange("%s property '%s' has been removed for %s", title, removedProperty, executable.getDisplayName())); Stream<DescriptiveChange> addedProperties = Sets.difference(current, previous).stream()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSink.java
* required to be a {@link BufferedOutputStream} in order to allow implementations to simply * delegate to {@link #openStream()} when the stream returned by that method does not benefit from * additional buffering (for example, a {@code ByteArrayOutputStream}). This method returns a new, * independent stream each time it is called. * * <p>The caller is responsible for ensuring that the returned stream is closed. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 5.5K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteSink.java
* required to be a {@link BufferedOutputStream} in order to allow implementations to simply * delegate to {@link #openStream()} when the stream returned by that method does not benefit from * additional buffering (for example, a {@code ByteArrayOutputStream}). This method returns a new, * independent stream each time it is called. * * <p>The caller is responsible for ensuring that the returned stream is closed. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 5.5K bytes - Viewed (0)