Skip navigation links
B C D E H I K L N O P R S T U V 

B

Broadcast - Interface in rxbroadcast
A Broadcast represents both a producer and subscriber of messages.
BroadcastOrder<M,T> - Interface in rxbroadcast
An order for broadcast message receipt.

C

CausalOrder<T> - Class in rxbroadcast
 
CausalOrder(Sender) - Constructor for class CausalOrder
 
CausalOrderProtobufSerializer<T> - Class in rxbroadcast
 
CausalOrderProtobufSerializer(Serializer<T>) - Constructor for class CausalOrderProtobufSerializer
 
compareTo(Sender) - Method in class Sender
 

D

decode(byte[]) - Method in class CausalOrderProtobufSerializer
 
decode(byte[]) - Method in class KryoSerializer
 
decode(byte[]) - Method in class ObjectSerializer
 
decode(byte[]) - Method in interface Serializer
 
decode(byte[]) - Method in class SingleSourceFifoOrderProtobufSerializer
 
deserialize(byte[]) - Method in class KryoSerializer
 
DROP_LATE - Static variable in class SingleSourceFifoOrder
 

E

encode(VectorTimestamped<T>) - Method in class CausalOrderProtobufSerializer
 
encode(T) - Method in class KryoSerializer
 
encode(T) - Method in class ObjectSerializer
 
encode(T) - Method in interface Serializer
 
encode(Timestamped<T>) - Method in class SingleSourceFifoOrderProtobufSerializer
 
equals(Object) - Method in class Sender
 
equals(Object) - Method in class VectorTimestamped
 

H

hashCode() - Method in class Sender
 
hashCode() - Method in class VectorTimestamped
 

I

InMemoryBroadcast - Class in rxbroadcast
A Broadcast implementation that works in-memory.
InMemoryBroadcast() - Constructor for class InMemoryBroadcast
Creates an instance of InMemoryBroadcast.

K

KryoSerializer<T> - Class in rxbroadcast
 
KryoSerializer() - Constructor for class KryoSerializer
 

L

LamportClock - Class in rxbroadcast.time
A clock used to generate Lamport timestamps.
LamportClock() - Constructor for class LamportClock
Creates an instance of LamportClock.

N

NoOrder<T> - Class in rxbroadcast
A basic ordering of broadcasted values.
NoOrder() - Constructor for class NoOrder
 

O

ObjectSerializer<T> - Class in rxbroadcast
 
ObjectSerializer() - Constructor for class ObjectSerializer
 

P

prepare(T) - Method in interface BroadcastOrder
Prepare the message for sending.
prepare(T) - Method in class CausalOrder
 
prepare(T) - Method in class NoOrder
Prepare the message for sending.
prepare(T) - Method in class SingleSourceFifoOrder
 

R

receive(Sender, Consumer<T>, M) - Method in interface BroadcastOrder
Handle receipt of the given message.
receive(Sender, Consumer<T>, VectorTimestamped<T>) - Method in class CausalOrder
 
receive(Sender, Consumer<T>, T) - Method in class NoOrder
Handle receipt of the given message.
receive(Sender, Consumer<T>, Timestamped<T>) - Method in class SingleSourceFifoOrder
 
rxbroadcast - package rxbroadcast
 
rxbroadcast.time - package rxbroadcast.time
 

S

send(Object) - Method in interface Broadcast
Broadcasts the given value when the returned Observable is subscribed to.
send(Object) - Method in class InMemoryBroadcast
Broadcasts the given value when the returned Observable is subscribed to.
send(Object) - Method in class UdpBroadcast
 
Sender - Class in rxbroadcast
 
serialize(Object) - Method in class KryoSerializer
 
Serializer<T> - Interface in rxbroadcast
 
set(long) - Method in class LamportClock
Updates this clock to account for the given incoming timestamp.
SingleSourceFifoOrder<T> - Class in rxbroadcast
 
SingleSourceFifoOrder() - Constructor for class SingleSourceFifoOrder
 
SingleSourceFifoOrder(SingleSourceFifoOrder.SingleSourceFifoOrderQueueOption) - Constructor for class SingleSourceFifoOrder
 
SingleSourceFifoOrder.SingleSourceFifoOrderQueueOption - Enum in rxbroadcast
 
SingleSourceFifoOrderProtobufSerializer<T> - Class in rxbroadcast
 
SingleSourceFifoOrderProtobufSerializer(Serializer<T>) - Constructor for class SingleSourceFifoOrderProtobufSerializer
 

T

tick(LongFunction<T>) - Method in class LamportClock
 
tick(Supplier<T>) - Method in class LamportClock
 
time() - Method in class LamportClock
Returns the current clock timestamp.
timestamp - Variable in class VectorTimestamped
 
toString() - Method in class Sender
 
toString() - Method in class LamportClock
 
toString() - Method in class VectorTimestamped
 

U

UdpBroadcast<T> - Class in rxbroadcast
 
UdpBroadcast(DatagramSocket, InetSocketAddress, Serializer<T>, Function<Sender, BroadcastOrder<T, Object>>) - Constructor for class UdpBroadcast
 
UdpBroadcast(DatagramSocket, InetSocketAddress, Serializer<T>, BroadcastOrder<T, Object>) - Constructor for class UdpBroadcast
 
UdpBroadcast(DatagramSocket, InetSocketAddress, BroadcastOrder<T, Object>) - Constructor for class UdpBroadcast
 
UdpBroadcast(DatagramSocket, InetSocketAddress, Function<Sender, BroadcastOrder<T, Object>>) - Constructor for class UdpBroadcast
 

V

value - Variable in class VectorTimestamped
 
valueOf(String) - Static method in enum SingleSourceFifoOrder.SingleSourceFifoOrderQueueOption
Returns the enum constant of this type with the specified name.
values() - Static method in enum SingleSourceFifoOrder.SingleSourceFifoOrderQueueOption
Returns an array containing the constants of this enum type, in the order they are declared.
valuesOfType(Class<T>) - Method in interface Broadcast
Returns a (hot) Observable stream of broadcasted values.
valuesOfType(Class<T>) - Method in class InMemoryBroadcast
Returns a (hot) Observable stream of broadcasted values.
valuesOfType(Class<V>) - Method in class UdpBroadcast
 
VectorTimestamped<T> - Class in rxbroadcast
Represents a value of type T that has been timestamped with a VectorTimestamp.
VectorTimestamped(T, VectorTimestamp) - Constructor for class VectorTimestamped
Creates an instance of VectorTimestamped that associates the given vector timestamp with the given value.
B C D E H I K L N O P R S T U V 
Skip navigation links