- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,150 for IsStream (0.16 sec)
-
src/main/java/org/codelibs/fess/util/QueryStringBuilder.java
queryBuf.append(escapeQuery(query)); } stream(params.getExtraQueries()) .of(stream -> stream.filter(q -> StringUtil.isNotBlank(q) && q.length() <= maxQueryLength).forEach(q -> { appendQuery(queryBuf, q); })); stream(params.getFields()).of(stream -> stream.forEach(entry -> { final String key = entry.getKey();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Serialization.java
Map<K, V> map, ObjectOutputStream stream) throws IOException { stream.writeInt(map.size()); for (Map.Entry<K, V> entry : map.entrySet()) { stream.writeObject(entry.getKey()); stream.writeObject(entry.getValue()); } } /** * Populates a map by reading an input stream, as part of deserialization. See {@link #writeMap} * for the data format. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Mar 06 16:06:58 UTC 2023 - 8.5K bytes - Viewed (0) -
tensorflow/cc/experimental/libtf/impl/iostream_test.cc
TEST(OStreamTest, TestInt64) { Int64 x(42); std::stringstream stream; stream << x; ASSERT_EQ(stream.str(), "42"); } TEST(OStreamTest, TestFloat32) { Float32 x(0.375); // Exactly representable as a float. std::stringstream stream; stream << x; ASSERT_EQ(stream.str(), "0.375"); } TEST(OStreamTest, TestString) { String s("foo"); std::stringstream stream; stream << s; ASSERT_EQ(stream.str(), "foo"); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 18 09:47:46 UTC 2024 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
// the stream. If newStreamHandler returns an error, the stream is rejected. If not, the // stream is accepted and registered with the connection. func (c *connection) newSpdyStream(stream *spdystream.Stream) { replySent := make(chan struct{}) err := c.newStreamHandler(stream, replySent) rejectStream := (err != nil) if rejectStream { klog.Warningf("Stream rejected: %v", err) stream.Reset() return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/action/FessUserBean.java
} public boolean hasRole(final String role) { return stream(user.getRoleNames()).get(stream -> stream.anyMatch(s -> s.equals(role))); } public boolean hasRoles(final String[] acceptedRoles) { return stream(user.getRoleNames()) .get(stream -> stream.anyMatch(s1 -> stream(acceptedRoles).get(s3 -> s3.anyMatch(s2 -> s2.equals(s1))))); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/btree/ByteOutputTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 2.5K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/BaseExecSpec.java
* completes. Defaults to an empty stream. * * @return The standard input stream. */ InputStream getStandardInput(); /** * Sets the output stream to consume standard output from the process executing the command. The stream is closed * after the process completes. * * @param outputStream The standard output stream for the process. Must not be null. * @return this */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 3.3K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_context.h
} // Returns a device-to-device stream, in round-robin fashion. se::Stream* GetDeviceToDeviceStream(); Status ThenExecute(Device* device, stream_executor::Stream* stream, std::function<void()> func) override; private: bool UseMultipleStreams() const { return stream_ != host_to_device_stream_; } // The main compute stream of the device, used to synchronize the transfer
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 5.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/problems/DefaultProblemDiagnosticsFactoryTest.groovy
given: def stream = factory.newStream() stream.forCurrentCaller() stream.forCurrentCaller() expect: stream.forCurrentCaller().stack.empty def failure1 = new Exception("broken") def diagnostics1 = stream.forCurrentCaller(failure1) diagnostics1.exception == failure1
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 17:15:42 UTC 2024 - 5.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/source/PrintStreamLoggingSystemTest.groovy
stream = printStream } } private final CurrentBuildOperationRef currentBuildOperationRef = CurrentBuildOperationRef.instance() def onReplacesOriginalStreamAndRemovesWhenRestored() { when: def snapshot = loggingSystem.startCapture() then: stream != originalStream when: loggingSystem.restore(snapshot) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 7.4K bytes - Viewed (0)