Package co.paralleluniverse.strands.channels

Interface Mix<M>

All Superinterfaces:

java.lang.AutoCloseable, Port<M>, PortAutoCloseable, ReceivePort<M>

All Known Implementing Classes:

ReceivePortGroup

public interface Mix<M>
extends ReceivePort<M>

ReceivePort with Mix operations.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	Mix.Mode
static class	Mix.SoloEffect
static class	Mix.State

Nested classes/interfaces inherited from interface co.paralleluniverse.strands.channels.ReceivePort

ReceivePort.EOFException

Method Summary

Modifier and Type	Method	Description
<T extends ReceivePort<? extends M>> void	add(T... items)
Mix.SoloEffect	getSoloEffect()
<T extends ReceivePort<? extends M>> java.util.Map<T,Mix.State>	getState(T... items)
<T extends ReceivePort<? extends M>> void	remove(T... items)
void	setSoloEffect(Mix.SoloEffect effect)
<T extends ReceivePort<? extends M>> void	setState(Mix.State state, T... items)
<T extends ReceivePort<? extends M>> void	setState(java.util.Map<T,Mix.State> states)

Methods inherited from interface co.paralleluniverse.strands.channels.PortAutoCloseable

close, isClosed

Methods inherited from interface co.paralleluniverse.strands.channels.ReceivePort

receive, receive, receive, tryReceive

Method Detail

add

<T extends ReceivePort<? extends M>> void add(T... items)
                                       throws SuspendExecution,
                                              java.lang.InterruptedException

Throws:

SuspendExecution

java.lang.InterruptedException

remove

<T extends ReceivePort<? extends M>> void remove(T... items)
                                          throws SuspendExecution,
                                                 java.lang.InterruptedException

Parameters:

items - If null or empty, all items will be removed.

Throws:

SuspendExecution

java.lang.InterruptedException

getState

<T extends ReceivePort<? extends M>> java.util.Map<T,Mix.State> getState(T... items)

Parameters:

items - If null or empty, all items will be removed.

setState

<T extends ReceivePort<? extends M>> void setState(Mix.State state,
                                                   T... items)
                                            throws SuspendExecution,
                                                   java.lang.InterruptedException

Parameters:

items - If null or empty, all items state will be set to state.

Throws:

SuspendExecution

java.lang.InterruptedException

setState

<T extends ReceivePort<? extends M>> void setState(java.util.Map<T,Mix.State> states)
                                            throws SuspendExecution,
                                                   java.lang.InterruptedException

Throws:

SuspendExecution

java.lang.InterruptedException

getSoloEffect

Mix.SoloEffect getSoloEffect()

setSoloEffect

void setSoloEffect(Mix.SoloEffect effect)
            throws SuspendExecution,
                   java.lang.InterruptedException

Throws:

SuspendExecution

java.lang.InterruptedException