Package org.apache.unomi.graphql.servlet.websocket

Class ExecutionResultSubscriber

java.lang.Object

io.reactivex.subscribers.DefaultSubscriber<graphql.ExecutionResult>

org.apache.unomi.graphql.servlet.websocket.ExecutionResultSubscriber

All Implemented Interfaces:

io.reactivex.FlowableSubscriber<graphql.ExecutionResult>, org.reactivestreams.Subscriber<graphql.ExecutionResult>

public class ExecutionResultSubscriber
extends io.reactivex.subscribers.DefaultSubscriber<graphql.ExecutionResult>

Constructor Summary

Constructors

Constructor	Description
ExecutionResultSubscriber(String id, org.eclipse.jetty.websocket.api.RemoteEndpoint remote)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)
void	onNext(graphql.ExecutionResult result)
void	unsubscribe()

Methods inherited from class io.reactivex.subscribers.DefaultSubscriber

cancel, onStart, onSubscribe, request

Methods inherited from class java.lang.Object

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

Constructor Details

ExecutionResultSubscriber

public ExecutionResultSubscriber(String id,
 org.eclipse.jetty.websocket.api.RemoteEndpoint remote)

Method Details

onNext

public void onNext(graphql.ExecutionResult result)

onError

public void onError(Throwable t)

onComplete

public void onComplete()

unsubscribe

public void unsubscribe()