类 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
-
-
方法概要
所有方法 静态方法 实例方法 具体方法 修饰符和类型 方法 说明 AbstractClientStreamconnection(Connection connection)voidexecute(Runnable runnable)ConnectiongetConnection()ConsumerModelgetConsumerModel()AbstractClientStreamservice(ConsumerModel model)static AbstractClientStreamstream(URL url)static UnaryClientStreamunary(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
-
从接口继承的方法 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
-
-