com.duoec.graphql.core.subscribe

类 GraphqlSubscriber

java.lang.Object

com.duoec.graphql.core.subscribe.GraphqlSubscriber

所有已实现的接口:

org.reactivestreams.Subscriber<graphql.ExecutionResult>

public class GraphqlSubscriber
extends Object
implements org.reactivestreams.Subscriber<graphql.ExecutionResult>

订阅器，每个会议是一个新的对象

作者:

xuwenzhen

构造器概要

构造器

构造器和说明
GraphqlSubscriber(javax.websocket.Session session)

方法概要

限定符和类型	方法和说明
void	addEmitter(io.reactivex.ObservableEmitter<Object> emitter)
void	cancelSubscription()
Set<io.reactivex.ObservableEmitter<Object>>	getEmitters()
String	getId()
javax.websocket.Session	getSession()
void	onComplete()
void	onError(Throwable t)
void	onNext(graphql.ExecutionResult er)
void	onSubscribe(org.reactivestreams.Subscription subscriber)
void	setId(String id)

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

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

构造器详细资料

GraphqlSubscriber

public GraphqlSubscriber(javax.websocket.Session session)

方法详细资料

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscriber)

指定者:

onSubscribe 在接口中 org.reactivestreams.Subscriber<graphql.ExecutionResult>

onNext

public void onNext(graphql.ExecutionResult er)

指定者:

onNext 在接口中 org.reactivestreams.Subscriber<graphql.ExecutionResult>

onError

public void onError(Throwable t)

指定者:

onError 在接口中 org.reactivestreams.Subscriber<graphql.ExecutionResult>

onComplete

public void onComplete()

指定者:

onComplete 在接口中 org.reactivestreams.Subscriber<graphql.ExecutionResult>

cancelSubscription

public void cancelSubscription()

getSession

public javax.websocket.Session getSession()

addEmitter

public void addEmitter(io.reactivex.ObservableEmitter<Object> emitter)

getEmitters

public Set<io.reactivex.ObservableEmitter<Object>> getEmitters()

setId

public void setId(String id)

getId

public String getId()