Package com.offbynull.coroutines.user

Class CoroutineWriter

java.lang.Object

com.offbynull.coroutines.user.CoroutineWriter

public final class CoroutineWriter
extends java.lang.Object

Writes out (serializes) the current state of a CoroutineRunner object.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CoroutineWriter.CoroutineSerializer	Coroutine serializer.
static class	CoroutineWriter.DefaultCoroutineSerializer	Default implementation of CoroutineWriter.CoroutineSerializer (uses Java's built-in serialization mechanism).

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Map	interceptersMap
private CoroutineWriter.CoroutineSerializer	serializer
private java.util.Map	updatersMap

Constructor Summary

Constructors

Constructor	Description
CoroutineWriter()	Construct a CoroutineWriter object.
CoroutineWriter(CoroutineWriter.CoroutineSerializer serializer, SerializedState.FrameUpdatePoint[] frameUpdatePoints, SerializedState.FrameInterceptPoint[] frameInterceptPoints)	Constructs a CoroutineWriter object.
CoroutineWriter(SerializedState.FrameInterceptPoint[] frameInterceptPoints)	Constructs a CoroutineWriter.
CoroutineWriter(SerializedState.FrameUpdatePoint[] frameUpdatePoints)	Constructs a CoroutineWriter.
CoroutineWriter(SerializedState.FrameUpdatePoint[] frameUpdatePoints, SerializedState.FrameInterceptPoint[] frameInterceptPoints)	Constructs a CoroutineWriter.

Method Summary

Modifier and Type	Method	Description
private int[]	clearContinuationReferences(java.lang.Object[] objects, Continuation cn)
SerializedState	deconstruct(CoroutineRunner runner)	Deconstructs a CoroutineRunner object to a serializable state.
byte[]	write(CoroutineRunner runner)	Serializes a CoroutineRunner object as a byte array.

Methods inherited from class java.lang.Object

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

Field Detail

serializer

private final CoroutineWriter.CoroutineSerializer serializer

updatersMap

private final java.util.Map updatersMap

interceptersMap

private final java.util.Map interceptersMap

Constructor Detail

CoroutineWriter

public CoroutineWriter()

Construct a CoroutineWriter object. Equivalent to calling new CoroutineWriter(new DefaultCoroutineSerializer(), new FrameUpdatePoint[0], new FrameInterceptPoint[0]).

CoroutineWriter

public CoroutineWriter(SerializedState.FrameUpdatePoint[] frameUpdatePoints)

Constructs a CoroutineWriter. Equivalent to calling new CoroutineWriter(new DefaultCoroutineSerializer(), frameUpdatePoints, new FrameInterceptPoint[0]).

Parameters:

frameUpdatePoints - frame update points

Throws:

java.lang.IllegalArgumentException - if frameUpdatePoints contains more than one entry for the same identifier (className/oldMethodId/newMethodId/continuationPoint)

java.lang.NullPointerException - if any argument is null

CoroutineWriter

public CoroutineWriter(SerializedState.FrameInterceptPoint[] frameInterceptPoints)

Constructs a CoroutineWriter. Equivalent to calling new CoroutineWriter(new DefaultCoroutineSerializer(), new FrameUpdatePoint[0], frameInterceptPoints).

Parameters:

frameInterceptPoints - frame intercept points

Throws:

java.lang.IllegalArgumentException - if frameInterceptPoints contains more than one entry for the same identifier (className/methodId/continuationPoint)

java.lang.NullPointerException - if any argument is null

CoroutineWriter

public CoroutineWriter(SerializedState.FrameUpdatePoint[] frameUpdatePoints,
                       SerializedState.FrameInterceptPoint[] frameInterceptPoints)

Constructs a CoroutineWriter. Equivalent to calling new CoroutineWriter(new DefaultCoroutineSerializer(), frameUpdatePoints, frameInterceptPoints).

Parameters:

frameUpdatePoints - frame update points

frameInterceptPoints - frame intercept points

Throws:

java.lang.IllegalArgumentException - if frameUpdatePoints contains more than one entry for the same identifier (className/oldMethodId/newMethodId/continuationPoint), or if frameInterceptPoints contains more than one entry for the same identifier (className/methodId/continuationPoint)

java.lang.NullPointerException - if any argument is null

CoroutineWriter

public CoroutineWriter(CoroutineWriter.CoroutineSerializer serializer,
                       SerializedState.FrameUpdatePoint[] frameUpdatePoints,
                       SerializedState.FrameInterceptPoint[] frameInterceptPoints)

Constructs a CoroutineWriter object.

Parameters:

serializer - serializer to write out the coroutine state

frameUpdatePoints - frame update points

frameInterceptPoints - frame intercept points

Throws:

java.lang.NullPointerException - if any argument is null or contains null

java.lang.IllegalArgumentException - if frameUpdatePoints contains more than one entry for the same identifier (className/oldMethodId/newMethodId/continuationPoint), or if frameInterceptPoints contains more than one entry for the same identifier (className/methodId/continuationPoint)

Method Detail

write

public byte[] write(CoroutineRunner runner)

Serializes a CoroutineRunner object as a byte array.

Parameters:

runner - coroutine runner to serialize

Returns:

runner serialized to byte array

Throws:

java.lang.NullPointerException - if any argument is null

java.lang.IllegalArgumentException - if failed to serialize

deconstruct

public SerializedState deconstruct(CoroutineRunner runner)

Deconstructs a CoroutineRunner object to a serializable state.

Parameters:

runner - coroutine runner to deconstruct

Returns:

deconstructed representation of CoroutineRunner

Throws:

java.lang.NullPointerException - if any argument is null

java.lang.IllegalArgumentException - if failed to deconstruct

clearContinuationReferences

private int[] clearContinuationReferences(java.lang.Object[] objects,
                                          Continuation cn)