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

类 AbstractServerStream

java.lang.Object

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

org.apache.dubbo.rpc.protocol.tri.AbstractServerStream

所有已实现的接口:

Stream

直接已知子类:

ServerStream, UnaryServerStream

public abstract class AbstractServerStream
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

方法概要

修饰符和类型	方法	说明
void	execute(Runnable runnable)
Invoker<?>	getInvoker()
List<MethodDescriptor>	getMethodDescriptors()
ProviderModel	getProviderModel()
AbstractServerStream	invoker(Invoker<?> invoker)
AbstractServerStream	methods(List<MethodDescriptor> methods)
AbstractServerStream	service(ServiceDescriptor sd)
static AbstractServerStream	stream(URL url)
static AbstractServerStream	unary(URL url)

从类继承的方法 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 AbstractServerStream unary(URL url)

stream

public static AbstractServerStream stream(URL url)

getMethodDescriptors

public List<MethodDescriptor> getMethodDescriptors()

methods

public AbstractServerStream methods(List<MethodDescriptor> methods)

getInvoker

public Invoker<?> getInvoker()

getProviderModel

public ProviderModel getProviderModel()

execute

public void execute(Runnable runnable)

指定者:

execute 在接口中 Stream

覆盖:

execute 在类中 AbstractStream

service

public AbstractServerStream service(ServiceDescriptor sd)

invoker

public AbstractServerStream invoker(Invoker<?> invoker)