- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 749 for channels (0.05 seconds)
-
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
*/ package okhttp3 import java.io.IOException import java.io.InputStream import java.io.OutputStream import java.net.InetAddress import java.net.SocketAddress import java.net.SocketException import java.nio.channels.SocketChannel import java.util.function.BiFunction import javax.net.ssl.HandshakeCompletedListener import javax.net.ssl.SSLParameters import javax.net.ssl.SSLSession import javax.net.ssl.SSLSocket
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 7.4K 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) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.util.concurrent.InterruptibleTask.Blocker; import java.nio.channels.spi.AbstractInterruptibleChannel; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.locks.LockSupport; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.util.concurrent.InterruptibleTask.Blocker; import java.nio.channels.spi.AbstractInterruptibleChannel; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.locks.LockSupport; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java
*/ package jcifs.internal.smb2.rdma.tcp; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketTimeoutException; import java.nio.ByteBuffer; import java.nio.channels.SocketChannel; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.internal.smb2.rdma.RdmaConnection; import jcifs.internal.smb2.rdma.RdmaMemoryRegion;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 8.8K bytes - Click Count (0) -
build-tools-internal/src/main/groovy/elasticsearch.ide.gradle
under the License.'''.stripIndent() } } } } } } } /** * Parses a given XML file, applies a set of changes, and writes those changes back to the original file. * * @param path Path to existing XML file * @param action Action to perform on parsed XML document * @param preface optional front matter to add after the XML declaration
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Fri Sep 24 19:34:12 GMT 2021 - 8.8K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ElasticsearchTestBasePlugin.java
// TODO: only open these for mockito when it is modularized "--add-opens=java.base/java.security.cert=ALL-UNNAMED", "--add-opens=java.base/java.nio.channels=ALL-UNNAMED", "--add-opens=java.base/java.net=ALL-UNNAMED", "--add-opens=java.base/javax.net.ssl=ALL-UNNAMED", "--add-opens=java.base/java.nio.file=ALL-UNNAMED",Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Aug 24 22:14:49 GMT 2021 - 10.4K 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) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
.status("ICY 200 OK") .addHeader("Accept-Ranges: none") .addHeader("Content-Type: audio/mpeg") .addHeader("icy-br:128") .addHeader("ice-audio-info: bitrate=128;samplerate=44100;channels=2") .addHeader("icy-br:128") .addHeader("icy-description:Rock") .addHeader("icy-genre:riders") .addHeader("icy-name:A2RRock") .addHeader("icy-pub:1")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 133.3K bytes - Click Count (0)