This commit is contained in:
Arturo Bernal 2021-02-09 07:26:05 +01:00 committed by Oleg Kalnichevski
parent 744c9d8020
commit f2e9ad3b11
7 changed files with 11 additions and 11 deletions

View File

@ -48,13 +48,13 @@ public final class HttpAsyncCacheStorageAdaptor implements HttpAsyncCacheStorage
private final HttpCacheStorage cacheStorage;
public HttpAsyncCacheStorageAdaptor(final HttpCacheStorage cacheStorage) {
this.cacheStorage = Args.notNull(cacheStorage, "Cache strorage");
this.cacheStorage = Args.notNull(cacheStorage, "Cache storage");
}
@Override
public Cancellable putEntry(final String key, final HttpCacheEntry entry, final FutureCallback<Boolean> callback) {
Args.notEmpty(key, "Key");
Args.notNull(entry, "Cache ehtry");
Args.notNull(entry, "Cache entry");
Args.notNull(callback, "Callback");
try {
cacheStorage.putEntry(key, entry);

View File

@ -156,11 +156,11 @@ public abstract class AbstractSerializingAsyncCacheStorage<T, CAS> implements Ht
Args.notNull(callback, "Callback");
final ComplexCancellable complexCancellable = new ComplexCancellable();
final AtomicInteger count = new AtomicInteger(0);
atemmptUpdateEntry(key, casOperation, complexCancellable, count, callback);
attemptUpdateEntry(key, casOperation, complexCancellable, count, callback);
return complexCancellable;
}
private void atemmptUpdateEntry(
private void attemptUpdateEntry(
final String key,
final HttpCacheCASOperation casOperation,
final ComplexCancellable complexCancellable,
@ -195,7 +195,7 @@ public abstract class AbstractSerializingAsyncCacheStorage<T, CAS> implements Ht
if (numRetries >= maxUpdateRetries) {
callback.failed(new HttpCacheUpdateException("Cache update failed after " + numRetries + " retries"));
} else {
atemmptUpdateEntry(key, casOperation, complexCancellable, count, callback);
attemptUpdateEntry(key, casOperation, complexCancellable, count, callback);
}
}
}

View File

@ -68,7 +68,7 @@ public class FileResource extends Resource {
public byte[] get() throws ResourceIOException {
final File file = this.fileRef.get();
if (file == null) {
throw new ResourceIOException("Resouce already dispoased");
throw new ResourceIOException("Resource already disposed");
}
try (final InputStream in = new FileInputStream(file)) {
final ByteArrayBuffer buf = new ByteArrayBuffer(1024);
@ -93,7 +93,7 @@ public class FileResource extends Resource {
throw new ResourceIOException(ex.getMessage(), ex);
}
}
throw new ResourceIOException("Resouce already dispoased");
throw new ResourceIOException("Resource already disposed");
}
@Override

View File

@ -56,7 +56,7 @@ public class HeapResource extends Resource {
if (byteArray != null) {
return byteArray;
}
throw new ResourceIOException("Resouce already dispoased");
throw new ResourceIOException("Resource already disposed");
}
@Override

View File

@ -62,7 +62,7 @@ import org.slf4j.LoggerFactory;
/**
* Request execution handler in the asynchronous request execution chain
* responsbile for handling of request redirects.
* responsible for handling of request redirects.
* <p>
* Further responsibilities such as communication with the opposite
* endpoint is delegated to the next executor in the request execution

View File

@ -558,7 +558,7 @@ public class H2AsyncClientBuilder {
* One MUST explicitly close HttpClient with {@link CloseableHttpAsyncClient#close()}
* in order to stop and release the background thread.
* <p>
* Please note this method has no effect if the instance of HttpClient is configuted to
* Please note this method has no effect if the instance of HttpClient is configured to
* use a shared connection manager.
*
* @param maxIdleTime maximum time persistent connections can stay idle while kept alive

View File

@ -99,7 +99,7 @@ public class BasicDomainHandler implements CommonCookieAttributeHandler {
final String normalizedDomain = domain.startsWith(".") ? domain.substring(1) : domain;
if (host.endsWith(normalizedDomain)) {
final int prefix = host.length() - normalizedDomain.length();
// Either a full match or a prefix endidng with a '.'
// Either a full match or a prefix ending with a '.'
if (prefix == 0) {
return true;
}