Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for Channels (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top