xiaofei.library.shelly.domino

类 Domino<T,R>

java.lang.Object

xiaofei.library.shelly.domino.Domino<T,R>

类型参数:

T - the type of the input of this Domino

R - the type of the output of this Domino T是原本输入的参数类型，R是将传给下面的参数类型！

直接已知子类:

RetrofitDomino, RetrofitDomino2, TaskDomino

public class Domino<T,R>
extends java.lang.Object

Created by Xiaofei on 16/5/26. Domino class.

字段概要

字段

限定符和类型	字段和说明
protected static DominoCenter	DOMINO_CENTER
protected static TargetCenter	TARGET_CENTER

构造器概要

构造器

构造器和说明
Domino(java.lang.Object label) This constructor is deprecated.
Domino(java.lang.Object label, Tile<T,R> tile) This constructor is deprecated.

方法概要

限定符和类型	方法和说明
Domino<T,R>	background()
Domino<T,R>	backgroundQueue()
<U> RetrofitDomino<T,U>	beginRetrofitTask(AbstractRetrofitTask<R,U> task)
<U> RetrofitDomino2<T,R,U>	beginRetrofitTaskKeepingInput(AbstractRetrofitTask<R,U> task)
<U1,U2,S1,S2> TaskDomino<T,U2,S2>	beginTask(Task<R,U1,S1> task, Function2<R,U1,U2> func1, Function2<R,S1,S2> func2)
<U,S> TaskDomino<T,U,S>	beginTask(Task<R,U,S> task)
<U,S> TaskDomino<T,Pair<R,U>,S>	beginTaskKeepingInput(Task<R,U,S> task)
<U> Domino<T,U>	clear()
<S1,S2,V> Domino<T,V>	combine(Domino<? super R,S1> domino1, Domino<? super R,S2> domino2, Function2<? super S1,? super S2,? extends V> combiner)
<S1,S2,U1,U2,V> Domino<T,V>	combineTask(TaskDomino<? super R,S1,U1> taskDomino1, TaskDomino<? super R,S2,U2> taskDomino2, Function2<? super S1,? super S2,? extends V> combiner)
void	commit()
<S extends Domino<T,?>> S	convert(DominoConverter<T,R,S> converter) Convert this Domino into another one.
<U> Domino<T,U>	dominoMap(Domino<? super R,? extends U> domino) Pass the input of this Domino to another Domino and regard its output as the output of this Domino.
Domino<T,R>	filter(Function1<? super R,java.lang.Boolean> filter)
<U> Domino<T,U>	flatMap(Function1<? super R,java.util.List<U>> map)
java.lang.Object	getLabel()
Tile<T,R>	getPlayer()
<U> Domino<T,U>	lift(Function1<java.util.concurrent.CopyOnWriteArrayList<R>,java.util.concurrent.CopyOnWriteArrayList<U>> function)
<U,S> Domino<T,U>	map(java.lang.Class<S> target, Function2<? super S,? super R,? extends U> map)
<U> Domino<T,U>	map(Function1<? super R,? extends U> map)
<U> Domino<T,U>	merge(Domino<? super R,? extends U>[] dominoes) Pass the input of this Domino to all the Dominoes in an array and merge their outputs into one, which is the output of this Domino.
<U> Domino<T,U>	merge(Domino<? super R,? extends U> domino1, Domino<? super R,? extends U> domino2) Pass the input of this Domino to another two Dominoes and merge their outputs into one, which is the output of this Domino.
<U> Domino<T,U>	merge(Domino<? super R,? extends U> domino1, Domino<? super R,? extends U> domino2, Domino<? super R,? extends U> domino3) Pass the input of this Domino to another three Dominoes and merge their outputs into one, which is the output of this Domino.
Domino<T,R>	perform(Action0 action0) Perform an action.
Domino<T,R>	perform(Action1<? super R> action1) Perform an action.
<U> Domino<T,R>	perform(java.lang.Class<? extends U> target, TargetAction0<? super U> targetAction0) Perform an action on all of the registered instances of a specified class.
<U> Domino<T,R>	perform(java.lang.Class<? extends U> target, TargetAction1<? super U,? super R> targetAction1) Perform an action on all of the registered instances of a specified class.
Domino<T,R>	perform(Domino<? super R,?> domino) Pass the input of this Domino to another Domino and play it.
void	play(java.util.concurrent.CopyOnWriteArrayList<T> input)
<U> Domino<T,U>	reduce(Function1<java.util.List<R>,? extends U> reducer)
Domino<T,R>	throttle(long windowDuration, java.util.concurrent.TimeUnit unit) Specify a window duration, during which there will be only one group of input to be passed into this Domino.
Domino<T,R>	uiThread()

从类继承的方法 java.lang.Object

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

字段详细资料

DOMINO_CENTER

protected static final DominoCenter DOMINO_CENTER

TARGET_CENTER

protected static final TargetCenter TARGET_CENTER

构造器详细资料

Domino

public Domino(java.lang.Object label)

This constructor is deprecated. Use Shelly.createXXX() instead.

参数:

label -

Domino

public Domino(java.lang.Object label,
              Tile<T,R> tile)

This constructor is deprecated. Use Shelly.createXXX() instead.

参数:

label -

方法详细资料

getLabel

public java.lang.Object getLabel()

getPlayer

public Tile<T,R> getPlayer()

convert

public <S extends Domino<T,?>> S convert(DominoConverter<T,R,S> converter)

Convert this Domino into another one.

类型参数:

S -

参数:

converter -

返回:

perform

public <U> Domino<T,R> perform(java.lang.Class<? extends U> target,
                               TargetAction0<? super U> targetAction0)

Perform an action on all of the registered instances of a specified class.

类型参数:

U -

参数:

target - the specified class.

targetAction0 - action to perform.

返回:

perform

public <U> Domino<T,R> perform(java.lang.Class<? extends U> target,
                               TargetAction1<? super U,? super R> targetAction1)

Perform an action on all of the registered instances of a specified class.

类型参数:

U -

参数:

target -

targetAction1 -

返回:

perform

public Domino<T,R> perform(Action0 action0)

Perform an action.

参数:

action0 -

返回:

perform

public Domino<T,R> perform(Action1<? super R> action1)

Perform an action.

参数:

action1 -

返回:

perform

public Domino<T,R> perform(Domino<? super R,?> domino)

Pass the input of this Domino to another Domino and play it.

参数:

domino -

返回:

dominoMap

public <U> Domino<T,U> dominoMap(Domino<? super R,? extends U> domino)

Pass the input of this Domino to another Domino and regard its output as the output of this Domino.

类型参数:

U -

参数:

domino -

返回:

merge

public <U> Domino<T,U> merge(Domino<? super R,? extends U> domino1,
                             Domino<? super R,? extends U> domino2)

Pass the input of this Domino to another two Dominoes and merge their outputs into one, which is the output of this Domino.

类型参数:

U -

参数:

domino1 -

domino2 -

返回:

merge

public <U> Domino<T,U> merge(Domino<? super R,? extends U> domino1,
                             Domino<? super R,? extends U> domino2,
                             Domino<? super R,? extends U> domino3)

Pass the input of this Domino to another three Dominoes and merge their outputs into one, which is the output of this Domino.

类型参数:

U -

参数:

domino1 -

domino2 -

domino3 -

返回:

merge

public <U> Domino<T,U> merge(Domino<? super R,? extends U>[] dominoes)

Pass the input of this Domino to all the Dominoes in an array and merge their outputs into one, which is the output of this Domino.

类型参数:

U -

参数:

dominoes -

返回:

combine

public <S1,S2,V> Domino<T,V> combine(Domino<? super R,S1> domino1,
                                     Domino<? super R,S2> domino2,
                                     Function2<? super S1,? super S2,? extends V> combiner)

combineTask

public <S1,S2,U1,U2,V> Domino<T,V> combineTask(TaskDomino<? super R,S1,U1> taskDomino1,
                                               TaskDomino<? super R,S2,U2> taskDomino2,
                                               Function2<? super S1,? super S2,? extends V> combiner)

background

public Domino<T,R> background()

uiThread

public Domino<T,R> uiThread()

backgroundQueue

public Domino<T,R> backgroundQueue()

throttle

public Domino<T,R> throttle(long windowDuration,
                            java.util.concurrent.TimeUnit unit)

Specify a window duration, during which there will be only one group of input to be passed into this Domino.

参数:

windowDuration -

unit -

返回:

lift

public <U> Domino<T,U> lift(Function1<java.util.concurrent.CopyOnWriteArrayList<R>,java.util.concurrent.CopyOnWriteArrayList<U>> function)

map

public <U> Domino<T,U> map(Function1<? super R,? extends U> map)

map

public <U,S> Domino<T,U> map(java.lang.Class<S> target,
                             Function2<? super S,? super R,? extends U> map)

flatMap

public <U> Domino<T,U> flatMap(Function1<? super R,java.util.List<U>> map)

filter

public Domino<T,R> filter(Function1<? super R,java.lang.Boolean> filter)

reduce

public <U> Domino<T,U> reduce(Function1<java.util.List<R>,? extends U> reducer)

clear

public <U> Domino<T,U> clear()

beginTask

public <U,S> TaskDomino<T,U,S> beginTask(Task<R,U,S> task)

beginTask

public <U1,U2,S1,S2> TaskDomino<T,U2,S2> beginTask(Task<R,U1,S1> task,
                                                   Function2<R,U1,U2> func1,
                                                   Function2<R,S1,S2> func2)

beginTaskKeepingInput

public <U,S> TaskDomino<T,Pair<R,U>,S> beginTaskKeepingInput(Task<R,U,S> task)

beginRetrofitTask

public <U> RetrofitDomino<T,U> beginRetrofitTask(AbstractRetrofitTask<R,U> task)

beginRetrofitTaskKeepingInput

public <U> RetrofitDomino2<T,R,U> beginRetrofitTaskKeepingInput(AbstractRetrofitTask<R,U> task)

play

public void play(java.util.concurrent.CopyOnWriteArrayList<T> input)

commit

public void commit()