- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for Channels (0.62 seconds)
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java
// "&rel=0" is also force-injected to prevent video recommendations from other channels rewritten = rewritten.replaceAll("\\@youtube\\(([a-zA-Z\\-_]+)\\,([^\\s<]+)\\)\\@", "<details> \n" + " <summary>📺 Watch the $1</summary> \n" +Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Mar 03 01:59:51 GMT 2026 - 11.3K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* href="https://kotlinlang.org/docs/coroutines-guide.html">Kotlin coroutines</a>, including <a * href="https://kotlinlang.org/docs/flow.html">Flow</a> and <a * href="https://kotlinlang.org/docs/channels.html">Channels</a>. Yet other usages are better served * by individual libraries that provide specialized support for particular use cases. * * <p>Disadvantages of EventBus include: * * <ul>
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 12.7K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteStreams.java
* <ol> * <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output * channel have their own file descriptors. Generally this only happens when both channels * are files or sockets. This performs zero copies - the bytes never enter userspace. * <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 31.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/ByteStreamsTest.java
import java.io.FilterInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.RandomAccessFile; import java.nio.channels.Channels; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.Arrays; import org.jspecify.annotations.NullUnmarked; /** * Unit test for {@link ByteStreams}. * * @author Chris Nokleberg */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/ByteStreamsTest.java
import java.io.FilterInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.RandomAccessFile; import java.nio.channels.Channels; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.Arrays; import org.jspecify.annotations.NullUnmarked; /** * Unit test for {@link ByteStreams}. * * @author Chris Nokleberg */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Files.java
try { RandomAccessFile raf = closer.register(new RandomAccessFile(file, mode == MapMode.READ_ONLY ? "r" : "rw")); FileChannel channel = closer.register(raf.getChannel()); return channel.map(mode, 0, size == -1 ? channel.size() : size); } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jan 05 22:13:21 GMT 2026 - 32.8K bytes - Click Count (0) -
android/guava/src/com/google/common/io/MoreFiles.java
} return attrs.size(); } @Override public byte[] read() throws IOException { try (SeekableByteChannel channel = Files.newByteChannel(path, options)) { return ByteStreams.toByteArray(Channels.newInputStream(channel), channel.size()); } } @Override public CharSource asCharSource(Charset charset) { if (options.length == 0) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Apr 14 16:07:06 GMT 2025 - 34.6K bytes - Click Count (0) -
src/main/java/org/codelibs/core/io/FileUtil.java
assertArgumentNotNull("file", file); final FileInputStream is = InputStreamUtil.create(file); try { final FileChannel channel = is.getChannel(); final long fileSize = ChannelUtil.size(channel); if (fileSize > maxSize) { throw new IORuntimeException(new IOException(
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Feb 12 12:10:45 GMT 2026 - 13.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/FilesTest.java
import java.io.FileNotFoundException; import java.io.IOException; import java.io.PrintWriter; import java.io.RandomAccessFile; import java.nio.ByteBuffer; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel.MapMode; import java.util.ArrayList; import java.util.List; import java.util.Random; import junit.framework.TestSuite; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 19 18:53:45 GMT 2026 - 22.8K bytes - Click Count (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
assertArgumentNotNull("out", out); final FileOutputStream os = OutputStreamUtil.create(out); try { final FileChannel channel = os.getChannel(); final ByteBuffer buffer = ByteBuffer.wrap(in); return ChannelUtil.write(channel, buffer); } finally { CloseableUtil.close(os); } } /**
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 45.2K bytes - Click Count (0)