类 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 booleanENABLE_ATTACHMENT_WRAP
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 StreamObserver<Object>asStreamObserver()TransportObserverasTransportObserver()voidexecute(Runnable runnable)ExecutorgetExecutor()MethodDescriptorgetMethodDescriptor()StringgetMethodName()MultipleSerializationgetMultipleSerialization()RequestgetRequest()StringgetSerializeType()ServiceDescriptorgetServiceDescriptor()StreamObserver<Object>getStreamSubscriber()TransportObservergetTransportSubscriber()URLgetUrl()AbstractStreammethod(MethodDescriptor md)AbstractStreammethodName(String methodName)AbstractStreamrequest(Request request)AbstractStreamserialize(String serializeType)voidsetServiceDescriptor(ServiceDescriptor serviceDescriptor)voidsubscribe(StreamObserver<Object> observer)voidsubscribe(TransportObserver observer)
-
-
-
方法详细资料
-
getRequest
public Request getRequest()
-
request
public AbstractStream request(Request request)
-
getExecutor
public Executor getExecutor()
-
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
public void subscribe(TransportObserver observer)
-
asStreamObserver
public StreamObserver<Object> asStreamObserver()
- 指定者:
asStreamObserver在接口中Stream
-
asTransportObserver
public TransportObserver asTransportObserver()
- 指定者:
asTransportObserver在接口中Stream
-
-