Package org.jruby.util

Class Join

java.lang.Object

org.jruby.util.Join

public final class Join
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	Join.AsyncCall
static class	Join.AsyncReaction
private static class	Join.Call
static class	Join.FastReaction
static class	Join.Reaction
static class	Join.Spec
private static class	Join.SyncCall
static class	Join.SyncReaction

Field Summary

Fields

Modifier and Type	Field	Description
private final long	asyncMask
private final Executor	executor
private long	mask
private final Join.Reaction[][]	reactionsPerChannel
static final Executor	TRIVIAL_EXECUTOR
private final LinkedList[]	writes

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Join(long asyncMask, Join.Reaction[][] reactionsPerChannel, Executor executor)

Method Summary

Modifier and Type	Method	Description
Object	call(int channel, Object message)
Object	call(Enum<?> channel, Object message)
boolean	isAsync(int channel)
void	send(int channel, Object message)
void	send(Enum<?> channel, Object message)
private void	sendRaw(int index, Object message)

Methods inherited from class java.lang.Object

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

Field Details

TRIVIAL_EXECUTOR

public static final Executor TRIVIAL_EXECUTOR

executor

private final Executor executor

writes

private final LinkedList[] writes

asyncMask

private final long asyncMask

mask

private long mask

reactionsPerChannel

private final Join.Reaction[][] reactionsPerChannel

Constructor Details

Join

private Join(long asyncMask,
 Join.Reaction[][] reactionsPerChannel,
 Executor executor)

Method Details

sendRaw

private void sendRaw(int index,
 Object message)

isAsync

public boolean isAsync(int channel)

send

public void send(int channel,
 Object message)

send

public void send(Enum<?> channel,
 Object message)

call

public Object call(int channel,
 Object message)

call

public Object call(Enum<?> channel,
 Object message)