- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 2,325 for strtab (0.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
* correlated by stream ID. * * * [onRequest] * * [onHeaders] (unless canceled) * * [onData] (optional sequence of data frames) * * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple * connections should expect repetition of stream IDs. * * Return true to request cancellation of a pushed stream. Note that this does not guarantee
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/util/internal/DisconnectableInputStreamTest.groovy
def instr = new DisconnectableInputStream(stream("some text"), toActionExecuter(executorFactory)) assertReads(instr, "some text") def nread = instr.read(new byte[20]) assertThat(nread, equalTo(-1)) instr.close() } @Test void buffersDataReadFromSourceInputStream() { def instr = new DisconnectableInputStream(stream("test1test2end"), toActionExecuter(executorFactory))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 8.5K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_recv_device_context_test.cc
new XlaHostSendDeviceContext(stream.get(), &gpu_dst, shape, done_event); TF_ASSERT_OK(device_context->CopyCPUTensorToDeviceSync( &origin_cpu_tensor, device_.get(), &device_tensor)); // Copy the GPU tensor back to CPU to check that copy worked. TF_ASSERT_OK(stream->Memcpy(dest_cpu_tensor.data(), gpu_dst, gpu_dst.size())); TF_ASSERT_OK(stream->BlockHostUntilDone());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 7.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/labeltype/AdminLabeltypeAction.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.admin.labeltype; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.stream.Collectors; import java.util.stream.Stream; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapUser.java
return stream(getPermissions()).get(stream -> stream.filter(s -> s.startsWith(fessConfig.getRoleSearchRolePrefix())) .map(s -> s.substring(1)).toArray(n -> new String[n])); } @Override public String[] getGroupNames() { final FessConfig fessConfig = ComponentUtil.getFessConfig();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/Encoder.java
* Provides a way to encode structured data to a backing byte stream. Implementations may buffer outgoing encoded bytes prior * to writing to the backing byte stream. */ public interface Encoder { /** * Returns an {@link OutputStream} that can be used to write raw bytes to the stream. */ OutputStream getOutputStream(); /** * Writes a raw byte value to the stream. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 4.1K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/test/impl/DefaultInputFileProperty.java
* limitations under the License. */ package org.gradle.internal.enterprise.test.impl; import org.gradle.internal.enterprise.test.InputFileProperty; import java.io.File; import java.util.stream.Stream; import java.util.stream.StreamSupport; class DefaultInputFileProperty implements InputFileProperty { private final String propertyName; private final Iterable<File> files;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jul 17 10:17:11 UTC 2023 - 1.3K bytes - Viewed (0) -
maven-slf4j-provider/src/main/java/org/apache/maven/slf4j/MavenSimpleLogger.java
protected void writeThrowable(Throwable t, PrintStream stream) { if (t == null) { return; } MessageBuilder builder = builder().failure(t.getClass().getName()); if (t.getMessage() != null) { builder.a(": ").failure(t.getMessage()); } stream.println(builder); printStackTrace(t, stream, ""); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Apr 03 17:49:40 UTC 2024 - 4.9K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.h
// Inserts the specified event at the end of the specified stream. void (*record_event)(const SP_Device* device, SP_Stream stream, SP_Event event, TF_Status* status); // Wait for the specified event at the end of the specified stream. void (*wait_for_event)(const SP_Device* const device, SP_Stream stream, SP_Event event, TF_Status* const status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 24 08:40:35 UTC 2022 - 21.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/GeoInfo.java
final String[] geoFields = fessConfig.getQueryGeoFieldsAsArray(); final Map<String, List<QueryBuilder>> geoMap = new HashMap<>(); StreamUtil.stream(request.getParameterMap()) .of(stream -> stream.filter(e -> e.getKey().startsWith("geo.") && e.getKey().endsWith(".point")).forEach(e -> { final String key = e.getKey(); for (final String geoField : geoFields) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.7K bytes - Viewed (0)