程序包 org.apache.dubbo.rpc.protocol.tri

类 AbstractClientStream

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.AbstractStream

org.apache.dubbo.rpc.protocol.tri.AbstractClientStream

所有已实现的接口:

Stream

直接已知子类:

ClientStream, UnaryClientStream

public abstract class AbstractClientStream
extends AbstractStream
implements Stream

嵌套类概要

从接口继承的嵌套类/接口 org.apache.dubbo.rpc.protocol.tri.Stream

Stream.OperationHandler, Stream.OperationResult

字段概要

从类继承的字段 org.apache.dubbo.rpc.protocol.tri.AbstractStream

ENABLE_ATTACHMENT_WRAP

从接口继承的字段 org.apache.dubbo.rpc.protocol.tri.Stream

LOGGER

方法概要

修饰符和类型	方法	说明
AbstractClientStream	connection(Connection connection)
void	execute(Runnable runnable)
Connection	getConnection()
ConsumerModel	getConsumerModel()
AbstractClientStream	service(ConsumerModel model)
static AbstractClientStream	stream(URL url)
static UnaryClientStream	unary(URL url, Executor executor)

从类继承的方法 org.apache.dubbo.rpc.protocol.tri.AbstractStream

asStreamObserver, asTransportObserver, getExecutor, getMethodDescriptor, getMethodName, getMultipleSerialization, getRequest, getSerializeType, getServiceDescriptor, getStreamSubscriber, getTransportSubscriber, getUrl, method, methodName, request, serialize, setServiceDescriptor, subscribe, subscribe

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

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

从接口继承的方法 org.apache.dubbo.rpc.protocol.tri.Stream

asStreamObserver, asTransportObserver, subscribe, subscribe

方法详细资料

unary

public static UnaryClientStream unary(URL url,
                                      Executor executor)

stream

public static AbstractClientStream stream(URL url)

service

public AbstractClientStream service(ConsumerModel model)

getConsumerModel

public ConsumerModel getConsumerModel()

connection

public AbstractClientStream connection(Connection connection)

getConnection

public Connection getConnection()

execute

public void execute(Runnable runnable)

指定者:

execute 在接口中 Stream

覆盖:

execute 在类中 AbstractStream