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

类 AbstractStream

java.lang.Object

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

所有已实现的接口:

Stream

直接已知子类:

AbstractClientStream, AbstractServerStream

public abstract class AbstractStream
extends Object
implements Stream

嵌套类概要

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

Stream.OperationHandler, Stream.OperationResult

字段概要

字段

修饰符和类型	字段	说明
static boolean	ENABLE_ATTACHMENT_WRAP

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

LOGGER

方法概要

修饰符和类型	方法	说明
StreamObserver<Object>	asStreamObserver()
TransportObserver	asTransportObserver()
void	execute(Runnable runnable)
Executor	getExecutor()
MethodDescriptor	getMethodDescriptor()
String	getMethodName()
MultipleSerialization	getMultipleSerialization()
Request	getRequest()
String	getSerializeType()
ServiceDescriptor	getServiceDescriptor()
StreamObserver<Object>	getStreamSubscriber()
TransportObserver	getTransportSubscriber()
URL	getUrl()
AbstractStream	method(MethodDescriptor md)
AbstractStream	methodName(String methodName)
AbstractStream	request(Request request)
AbstractStream	serialize(String serializeType)
void	setServiceDescriptor(ServiceDescriptor serviceDescriptor)
void	subscribe(StreamObserver<Object> observer)
void	subscribe(TransportObserver observer)

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

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

字段详细资料

ENABLE_ATTACHMENT_WRAP

public static final boolean ENABLE_ATTACHMENT_WRAP

方法详细资料

getRequest

public Request getRequest()

request

public AbstractStream request(Request request)

getExecutor

public Executor getExecutor()

execute

public void execute(Runnable runnable)

指定者:

execute 在接口中 Stream

getMethodName

public String getMethodName()

methodName

public AbstractStream methodName(String methodName)

method

public AbstractStream method(MethodDescriptor md)

getSerializeType

public String getSerializeType()

serialize

public AbstractStream serialize(String serializeType)

getMultipleSerialization

public MultipleSerialization getMultipleSerialization()

getStreamSubscriber

public StreamObserver<Object> getStreamSubscriber()

getTransportSubscriber

public TransportObserver getTransportSubscriber()

getMethodDescriptor

public MethodDescriptor getMethodDescriptor()

getServiceDescriptor

public ServiceDescriptor getServiceDescriptor()

setServiceDescriptor

public void setServiceDescriptor(ServiceDescriptor serviceDescriptor)

getUrl

public URL getUrl()

subscribe

public void subscribe(StreamObserver<Object> observer)

指定者:

subscribe 在接口中 Stream

subscribe

public void subscribe(TransportObserver observer)

指定者:

subscribe 在接口中 Stream

asStreamObserver

public StreamObserver<Object> asStreamObserver()

指定者:

asStreamObserver 在接口中 Stream

asTransportObserver

public TransportObserver asTransportObserver()

指定者:

asTransportObserver 在接口中 Stream