public final class HttpResources extends TcpResources
Disposable.Composite, Disposable.Swap
DEFAULT_POOL_ACQUIRE_TIMEOUT, DEFAULT_POOL_MAX_CONNECTIONS
DEFAULT_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<java.lang.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, preferNative
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
elastic, fixed, fixed, fixed, newConnection
colocate, create, create, create
public 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<java.lang.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.