- Sort Score
- Result 10 results
- Languages All
Results 561 - 570 of 849 for upstream (0.07 sec)
-
compat/maven-compat/src/test/java/org/apache/maven/SimpleLookup.java
private final List<Object> objects; public SimpleLookup(List<Object> objects) { this.objects = objects; } @Override public <T> T lookup(Class<T> type) { return objects.stream() .filter(type::isInstance) .map(type::cast) .findAny() .orElseThrow(() -> new LookupException("No service of type " + type)); } @Override
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2K bytes - Viewed (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/StringSettingsSource.java
super(settings, location); } /** * Gets the character sequence of this settings source. * * @return The underlying character stream, never {@code null}. * @deprecated instead use {@link #getContent()} */ @Deprecated public String getSettings() { return getContent(); }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
* limitations under the License. */ package okhttp3.internal.http2 import okhttp3.internal.http2.flowcontrol.WindowCounter interface FlowControlListener { /** * Notification that the receiving stream flow control window has changed. * [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SetsTest.java
import java.util.Set; import java.util.SortedSet; import java.util.TreeSet; import java.util.concurrent.CopyOnWriteArraySet; import java.util.function.BiConsumer; import java.util.stream.Collector; import java.util.stream.Stream; import junit.framework.Test; import junit.framework.TestCase; import junit.framework.TestSuite; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@code Sets}.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 48.6K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
when explicitly forbidden. * Fix: Throw a `SSLPeerUnverifiedException` when host verification fails. * Fix: MockWebServer explicitly closes sockets. (On some Android releases, closing the input stream and output stream of a socket is not sufficient. * Fix: Buffer outgoing HTTP/2 frames to limit how many outgoing frames are created. * Fix: Avoid crashing when cache writing fails due to a full disk.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
import java.io.*; import java.net.*; import java.util.*; import jcifs.smb1.util.LogStream; /** * This class simplifies communication for protocols that support * multiplexing requests. It encapsulates a stream and some protocol * knowledge (provided by a concrete subclass) so that connecting, * disconnecting, sending, and receiving can be syncronized * properly. Apparatus is provided to send and receive requests * concurrently.
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/DefaultConsumerPomArtifactTransformer.java
* under the License. */ package org.apache.maven.internal.transformation.impl; import javax.inject.Inject; import javax.inject.Named; import javax.inject.Singleton; import javax.xml.stream.XMLStreamException; import java.io.IOException; import java.io.Writer; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.util.ArrayList; import java.util.Collection;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Init.java
return OK; } config.setDefaultDispatcher(result.get("defaultDispatcher").getResult()); DispatcherMeta meta = secDispatcher.availableDispatchers().stream() .filter(d -> Objects.equals(config.getDefaultDispatcher(), d.name())) .findFirst() .orElseThrow(); if (!meta.fields().isEmpty()) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 12.1K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package sql import ( "encoding/json" "errors" "fmt" "math" "strings" "github.com/minio/minio/internal/s3select/jstream" "github.com/minio/simdjson-go" ) var ( errInvalidASTNode = errors.New("invalid AST Node") errExpectedBool = errors.New("expected bool")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 12K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/ConsumerPomBuilder.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.internal.transformation.impl; import javax.xml.stream.XMLStreamException; import java.io.IOException; import java.nio.file.Path; import org.apache.maven.api.model.Model; import org.apache.maven.model.building.ModelBuildingException;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.5K bytes - Viewed (0)