Class Rpc

ZezeJava/ZezeJava/src/main/java/Zeze/Net/Rpc.java:16–361

import org.jetbrains.annotations.Nullable;

public abstract class Rpc<TArgument extends Serializable, TResult extends Serializable> extends Protocol<TArgument> {
	protected static final @NotNull Logger logger = LogManager.getLogger(Rpc.class);

	public TResult Result;
	protected transient @Nullable Binary resultEncoded; // 如果设置了这个，发送结果的时候，优先使用这个编码过的。
	private long sessionId;
	private transient @Nullable ProtocolHandle<Rpc<TArgument, TResult>> responseHandle;
	private transient @Nullable TaskCompletionSource<TResult> future;
	private int timeout = 5000;
	private boolean isTimeout;
	private boolean isRequest = true;
	protected transient boolean sendResultDone; // XXX ugly

	@Override
	public int getFamilyClass() {
		return isRequest ? FamilyClass.Request : FamilyClass.Response;
	}

	public long getSessionId() {
		return sessionId;
	}

	public void setSessionId(long sessionId) {
		this.sessionId = sessionId;
	}

	public @Nullable ProtocolHandle<Rpc<TArgument, TResult>> getResponseHandle() {
		return responseHandle;
	}

	public void setResponseHandle(@Nullable ProtocolHandle<Rpc<TArgument, TResult>> handle) {
		responseHandle = handle;
	}

	public @Nullable TaskCompletionSource<TResult> getFuture() {
		return future;
	}

	public void setFuture(@Nullable TaskCompletionSource<TResult> future) {
		this.future = future;
	}

	public int getTimeout() {
		return timeout;
	}

	public void setTimeout(int timeout) {
		this.timeout = timeout;
	}

	public boolean isTimeout() {
		return isTimeout;
	}

	public void setIsTimeout(boolean isTimeout) {
		this.isTimeout = isTimeout;
	}