com.duoec.graphql.fetcher

类 SubscriptionDataFetcherProxy

java.lang.Object

com.duoec.graphql.fetcher.SubscriptionDataFetcherProxy

所有已实现的接口:

graphql.schema.DataFetcher

public class SubscriptionDataFetcherProxy
extends Object
implements graphql.schema.DataFetcher

作者:

xuwenzhen

字段概要

字段

限定符和类型	字段和说明
static Map<String,List<io.reactivex.ObservableEmitter<Object>>>	TOPIC_EMITTERS_MAP 存放各个个会话列表的Map key: topicName

构造器概要

构造器

构造器和说明
SubscriptionDataFetcherProxy()

方法概要

限定符和类型	方法和说明
Object	get(graphql.schema.DataFetchingEnvironment environment) This is called by the graphql engine to fetch the value.
String	getTopicName()
static void	removeEmitter(io.reactivex.ObservableEmitter<Object> emitter)
void	setTopicName(String topicName)

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

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

字段详细资料

TOPIC_EMITTERS_MAP

public static final Map<String,List<io.reactivex.ObservableEmitter<Object>>> TOPIC_EMITTERS_MAP

存放各个个会话列表的Map key: topicName

构造器详细资料

SubscriptionDataFetcherProxy

public SubscriptionDataFetcherProxy()

方法详细资料

get

public Object get(graphql.schema.DataFetchingEnvironment environment)
           throws Exception

This is called by the graphql engine to fetch the value. The DataFetchingEnvironment is a composite context object that tells you all you need to know about how to fetch a data value in graphql type terms.

指定者:

get 在接口中 graphql.schema.DataFetcher

参数:

environment - this is the data fetching environment which contains all the context you need to fetch a value

返回:

a value of type T. May be wrapped in a DataFetcherResult

抛出:

Exception - to relieve the implementations from having to wrap checked exceptions. Any exception thrown from a DataFetcher will eventually be handled by the registered DataFetcherExceptionHandler and the related field will have a value of null in the result.

getTopicName

public String getTopicName()

setTopicName

public void setTopicName(String topicName)

removeEmitter

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