com.github.jingshouyan.jrpc.server.service.impl

类 RpcImpl

java.lang.Object

com.github.jingshouyan.jrpc.server.service.impl.RpcImpl

所有已实现的接口:

Jrpc.AsyncIface, Rpc

public class RpcImpl
extends Object
implements Rpc

作者:

jingshouyan #date 2018/10/22 15:48

字段概要

字段

限定符和类型	字段和说明
private ServerActionHandler	handler

构造器概要

构造器

构造器和说明
RpcImpl(ServerActionHandler handler)

方法概要

限定符和类型	方法和说明
void	call(TokenBean token, ReqBean req, org.apache.thrift.async.AsyncMethodCallback<RspBean> resultHandler)
private io.reactivex.Single<RspBean>	run(TokenBean tokenBean, ReqBean reqBean, boolean oneway)
void	send(TokenBean token, ReqBean req, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)
private RspBean	toRspBean(Rsp rsp)

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

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

字段详细资料

handler

private final ServerActionHandler handler

构造器详细资料

RpcImpl

public RpcImpl(ServerActionHandler handler)

方法详细资料

call

public void call(TokenBean token,
                 ReqBean req,
                 org.apache.thrift.async.AsyncMethodCallback<RspBean> resultHandler)

指定者:

call 在接口中 Jrpc.AsyncIface

send

public void send(TokenBean token,
                 ReqBean req,
                 org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)

指定者:

send 在接口中 Jrpc.AsyncIface

run

private io.reactivex.Single<RspBean> run(TokenBean tokenBean,
                                         ReqBean reqBean,
                                         boolean oneway)

toRspBean

private RspBean toRspBean(Rsp rsp)