Top Description Fields Constructors Methods
io.r2dbc.spi

pack-priv Class DefaultLob<T>

extends Object
Class Inheritance
Imports
org.reactivestreams.Publisher, .Subscriber, .Subscription, java.util.concurrent.atomic.AtomicBoolean, .AtomicIntegerFieldUpdater
Abstract implementation for large object types.

Field Summary

Modifier and TypeField and Description
private static final AtomicIntegerFieldUpdater<DefaultLob<?>>
ATOMIC_CONSUMED

private static final AtomicIntegerFieldUpdater<DefaultLob<?>>
ATOMIC_DISCARD

private static final int
CONSUMED

private volatile int
consumed

private static final int
DISCARDED

private volatile int
discarded

private static final int
NOT_CONSUMED

private static final int
NOT_DISCARDED

private final Publisher<T>
p

Constructor Summary

AccessConstructor and Description
pack-priv
DefaultLob(Publisher<T> p)

Creates a new DefaultLob instance.

Method Summary

Modifier and TypeMethod and Description
pack-priv Publisher<Void>
discard()

Discard the content stream.

pack-priv Publisher<T>

Returns:

the content stream.
stream()

Returns the content stream.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

ATOMIC_CONSUMEDback to summary
private static final AtomicIntegerFieldUpdater<DefaultLob<?>> ATOMIC_CONSUMED
Annotations
@SuppressWarnings:unchecked
ATOMIC_DISCARDback to summary
private static final AtomicIntegerFieldUpdater<DefaultLob<?>> ATOMIC_DISCARD
Annotations
@SuppressWarnings:unchecked
CONSUMEDback to summary
private static final int CONSUMED
consumedback to summary
private volatile int consumed
DISCARDEDback to summary
private static final int DISCARDED
discardedback to summary
private volatile int discarded
NOT_CONSUMEDback to summary
private static final int NOT_CONSUMED
NOT_DISCARDEDback to summary
private static final int NOT_DISCARDED
pback to summary
private final Publisher<T> p

Constructor Detail

DefaultLobback to summary
pack-priv DefaultLob(Publisher<T> p)

Creates a new DefaultLob instance.

Method Detail

discardback to summary
pack-priv Publisher<Void> discard()

Discard the content stream.

streamback to summary
pack-priv Publisher<T> stream()

Returns the content stream.

Returns:Publisher<T>

the content stream.