public final class HttpResources extends TcpResources
Disposable.Composite, Disposable.SwapDEFAULT_POOL_ACQUIRE_TIMEOUT, DEFAULT_POOL_MAX_CONNECTIONSDEFAULT_IO_SELECT_COUNT, DEFAULT_IO_WORKER_COUNT, DEFAULT_NATIVE| Modifier and Type | Method and Description |
|---|---|
static void |
disposeLoopsAndConnections()
Shutdown the global
HttpResources without resetting them,
effectively cleaning up associated resources without creating new ones. |
static Mono<Void> |
disposeLoopsAndConnectionsLater()
Prepare to shutdown the global
HttpResources without resetting them,
effectively cleaning up associated resources without creating new ones. |
static HttpResources |
get()
Return the global HTTP resources for event loops and pooling
|
static HttpResources |
reset()
Reset http resources to default and return its instance
|
static HttpResources |
set(ConnectionProvider provider)
Update event loops resources and return the global HTTP resources
|
static HttpResources |
set(LoopResources loops)
Update pooling resources and return the global HTTP resources
|
_dispose, _disposeLater, acquire, daemon, dispose, disposeLater, disposeWhen, getOrCreate, isDisposed, onChannel, onClient, onDatagramChannel, onServer, onServerChannel, onServerSelect, preferNativeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitelastic, fixed, fixed, fixed, maxConnections, newConnectioncolocate, create, create, createpublic static HttpResources get()
public static HttpResources set(ConnectionProvider provider)
public static HttpResources set(LoopResources loops)
public static HttpResources reset()
public static void disposeLoopsAndConnections()
HttpResources without resetting them,
effectively cleaning up associated resources without creating new ones.public static Mono<Void> disposeLoopsAndConnectionsLater()
HttpResources without resetting them,
effectively cleaning up associated resources without creating new ones. This only
occurs when the returned Mono is subscribed to.Mono triggering the disposeLoopsAndConnections() when subscribed to.