Package com.github.ocraft.s2client.api

Class S2Client

java.lang.Object

io.reactivex.subscribers.DefaultSubscriber<Response>

com.github.ocraft.s2client.api.S2Client

All Implemented Interfaces:

io.reactivex.FlowableSubscriber<Response>, org.reactivestreams.Subscriber<Response>

public class S2Client
extends io.reactivex.subscribers.DefaultSubscriber<Response>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	S2Client.Builder

Method Summary

Modifier and Type	Method	Description
boolean	await()
boolean	fullStop()
int	getConnectTimeoutInMillis()
java.lang.String	getConnectToIp()
java.lang.Integer	getConnectToPort()
int	getRequestTimeoutInMillis()
boolean	isDone()
boolean	isTraced()
void	onComplete()
void	onError(java.lang.Throwable throwable)
void	onNext(Response response)
<T extends Request> void	request(BuilderSyntax<T> requestDataBuilder)
<T extends Request> void	request(T requestData)
<T extends Request> Response	requestSync(BuilderSyntax<T> requestDataBuilder)
<T extends Request,S extends Response> S	requestSync(BuilderSyntax<T> requestDataBuilder, java.lang.Class<S> responseClass)
<T extends Request> Response	requestSync(T requestData)
<T extends Request,S extends Response> S	requestSync(T requestData, java.lang.Class<S> responseClass)
io.reactivex.Flowable<Response>	responseStream()
static S2ClientSyntax	starcraft2Client()
boolean	stop()
java.lang.String	toString()
S2Client	untilReady()
S2Client	untilReady(java.lang.Runnable onPull)
io.reactivex.Maybe<Response>	waitForResponse(ResponseType responseType)

Methods inherited from class io.reactivex.subscribers.DefaultSubscriber

cancel, onStart, onSubscribe, request

Methods inherited from class java.lang.Object

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

Method Detail

starcraft2Client

public static S2ClientSyntax starcraft2Client()

responseStream

public io.reactivex.Flowable<Response> responseStream()

request

public <T extends Request> void request(T requestData)

request

public <T extends Request> void request(BuilderSyntax<T> requestDataBuilder)

requestSync

public <T extends Request> Response requestSync(T requestData)

waitForResponse

public io.reactivex.Maybe<Response> waitForResponse(ResponseType responseType)

requestSync

public <T extends Request> Response requestSync(BuilderSyntax<T> requestDataBuilder)

requestSync

public <T extends Request,S extends Response> S requestSync(T requestData,
                                                            java.lang.Class<S> responseClass)

requestSync

public <T extends Request,S extends Response> S requestSync(BuilderSyntax<T> requestDataBuilder,
                                                            java.lang.Class<S> responseClass)

isDone

public boolean isDone()

stop

public boolean stop()

fullStop

public boolean fullStop()

await

public boolean await()

onNext

public void onNext(Response response)

onError

public void onError(java.lang.Throwable throwable)

onComplete

public void onComplete()

getConnectToIp

public java.lang.String getConnectToIp()

getConnectToPort

public java.lang.Integer getConnectToPort()

getRequestTimeoutInMillis

public int getRequestTimeoutInMillis()

getConnectTimeoutInMillis

public int getConnectTimeoutInMillis()

isTraced

public boolean isTraced()

untilReady

public S2Client untilReady()
                    throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

untilReady

public S2Client untilReady(java.lang.Runnable onPull)
                    throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object