Top Description Methods
io.r2dbc.spi

public Interface Blob

Imports
org.reactivestreams.Publisher, .Subscriber, .Subscription, java.nio.ByteBuffer
Represents a handle to a large binary object.

Method Summary

Modifier and TypeMethod and Description
public Publisher<Void>

Returns:

a Publisher that termination is complete
discard()

Release any resources held by the Clob when not subscribing to the stream content.

public static Blob

Returns:

the Blob wrapper
from(Publisher<ByteBuffer>
the backing Publisher of ByteBuffer.
p)

Creates a new Blob wrapper that is backed by a Publisher of ByteBuffer.

public Publisher<ByteBuffer>

Returns:

a Publisher emitting ByteBuffer chunks.
stream()

Returns the content stream as a Publisher emitting ByteBuffer chunks.

Method Detail

discardback to summary
public Publisher<Void> discard()

Release any resources held by the Clob when not subscribing to the stream content.

Returns:Publisher<Void>

a Publisher that termination is complete

fromback to summary
public static Blob from(Publisher<ByteBuffer> p)

Creates a new Blob wrapper that is backed by a Publisher of ByteBuffer. The wrapper subscribes and cancels the subscription immediately on discard().

Parameters
p:Publisher<ByteBuffer>

the backing Publisher of ByteBuffer.

Returns:Blob

the Blob wrapper

streamback to summary
public Publisher<ByteBuffer> stream()

Returns the content stream as a Publisher emitting ByteBuffer chunks.

The content stream can be consumed ("subscribed to") only once. Subsequent consumptions result in a IllegalStateException.

Once subscribed, canceling the subscription releases resources associated with this Blob.

Returns:Publisher<ByteBuffer>

a Publisher emitting ByteBuffer chunks.