Package org.elasticsearch.common.io.stream

Class DelayableWriteable<T extends Writeable>

java.lang.Object

org.elasticsearch.common.io.stream.DelayableWriteable<T>

All Implemented Interfaces:

java.util.function.Supplier<T>, Writeable

public abstract class DelayableWriteable<T extends Writeable>
extends java.lang.Object
implements java.util.function.Supplier<T>, Writeable

A holder for Writeables that can delays reading the underlying Writeable when it is read from a remote node.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Method Summary

Modifier and Type	Method	Description
static <T extends Writeable> DelayableWriteable<T>	delayed(Writeable.Reader<T> reader, StreamInput in)	Build a DelayableWriteable that copies a buffer from the provided StreamInput and deserializes the buffer when Supplier.get() is called.
abstract boolean	isDelayed()
static <T extends Writeable> DelayableWriteable<T>	referencing(T reference)	Build a DelayableWriteable that wraps an existing object but is serialized so that deserializing it can be delayed.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Supplier

get

Methods inherited from interface org.elasticsearch.common.io.stream.Writeable

writeTo

Method Details

referencing

public static <T extends Writeable> DelayableWriteable<T> referencing(T reference)

Build a DelayableWriteable that wraps an existing object but is serialized so that deserializing it can be delayed.

delayed

public static <T extends Writeable> DelayableWriteable<T> delayed(Writeable.Reader<T> reader, StreamInput in) throws java.io.IOException

Build a DelayableWriteable that copies a buffer from the provided StreamInput and deserializes the buffer when Supplier.get() is called.

Throws:

java.io.IOException

isDelayed

public abstract boolean isDelayed()