reactor.netty.http

Class HttpResources

java.lang.Object

reactor.netty.tcp.TcpResources

reactor.netty.http.HttpResources

All Implemented Interfaces:

Disposable, ConnectionProvider, LoopResources

public final class HttpResources
extends TcpResources

Hold the default Http resources

Since:

0.6

Author:

Stephane Maldini

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.netty.resources.ConnectionProvider

ConnectionProvider.Builder, ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>>, ConnectionProvider.HostSpecificSpec, ConnectionProvider.MeterRegistrar

Nested classes/interfaces inherited from interface reactor.core.Disposable

Disposable.Composite, Disposable.Swap

Field Summary

Fields inherited from interface reactor.netty.resources.ConnectionProvider

DEFAULT_POOL_ACQUIRE_TIMEOUT, DEFAULT_POOL_LEASING_STRATEGY, DEFAULT_POOL_MAX_CONNECTIONS, DEFAULT_POOL_MAX_IDLE_TIME, DEFAULT_POOL_MAX_LIFE_TIME, LEASING_STRATEGY_FIFO, LEASING_STRATEGY_LIFO

Fields inherited from interface reactor.netty.resources.LoopResources

DEFAULT_IO_SELECT_COUNT, DEFAULT_IO_WORKER_COUNT, DEFAULT_NATIVE, DEFAULT_SHUTDOWN_QUIET_PERIOD, DEFAULT_SHUTDOWN_TIMEOUT

Method Summary

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 Mono<Void>	disposeLoopsAndConnectionsLater(java.time.Duration quietPeriod, java.time.Duration timeout) 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 pooling resources and return the global HTTP resources.
static HttpResources	set(LoopResources loops) Update event loops resources and return the global HTTP resources.

Methods inherited from class reactor.netty.tcp.TcpResources

_dispose, _disposeLater, _disposeLater, acquire, daemon, dispose, disposeLater, disposeWhen, getOrCreate, isDisposed, onChannel, onChannel, onChannelClass, onClient, onDatagramChannel, onServer, onServerChannel, onServerSelect, preferNative

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface reactor.netty.resources.ConnectionProvider

builder, create, create, elastic, elastic, elastic, fixed, fixed, fixed, fixed, fixed, maxConnections, newConnection

Methods inherited from interface reactor.netty.resources.LoopResources

colocate, create, create, create, disposeLater, hasNativeSupport

Method Detail

get

public static HttpResources get()

Return the global HTTP resources for event loops and pooling

Returns:

the global HTTP resources for event loops and pooling

set

public static HttpResources set(ConnectionProvider provider)

Update pooling resources and return the global HTTP resources. Note: The previous ConnectionProvider will be disposed.

Parameters:

provider - a new ConnectionProvider to replace the current

Returns:

the global HTTP resources

set

public static HttpResources set(LoopResources loops)

Update event loops resources and return the global HTTP resources. Note: The previous LoopResources will be disposed.

Parameters:

loops - a new LoopResources to replace the current

Returns:

the global HTTP resources

reset

public static HttpResources reset()

Reset http resources to default and return its instance

Returns:

the global HTTP resources

disposeLoopsAndConnections

public static void disposeLoopsAndConnections()

Shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones. This method is NOT blocking. It is implemented as fire-and-forget. Use disposeLoopsAndConnectionsLater() when you need to observe the final status of the operation, combined with Mono.block() if you need to synchronously wait for the underlying resources to be disposed.

disposeLoopsAndConnectionsLater

public static Mono<Void> disposeLoopsAndConnectionsLater()

Prepare to shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones. This only occurs when the returned Mono is subscribed to. The quiet period will be 2s and the timeout will be 15s

Returns:

a Mono triggering the disposeLoopsAndConnections() when subscribed to.

disposeLoopsAndConnectionsLater

public static Mono<Void> disposeLoopsAndConnectionsLater(java.time.Duration quietPeriod,
                                                         java.time.Duration timeout)

Prepare to shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones. This only occurs when the returned Mono is subscribed to. It is guaranteed that the disposal of the underlying LoopResources will not happen before quietPeriod is over. If a task is submitted during the quietPeriod, it is guaranteed to be accepted and the quietPeriod will start over.

Parameters:

quietPeriod - the quiet period as described above

timeout - the maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period

Returns:

a Mono triggering the disposeLoopsAndConnections() when subscribed to.

Since:

0.9.3