hera.client.stream

Class GrpcStreamSubscription<T>

java.lang.Object

hera.client.stream.GrpcStreamSubscription<T>

All Implemented Interfaces:

Subscription<T>

public class GrpcStreamSubscription<T>
extends java.lang.Object
implements Subscription<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected io.grpc.Context.CancellableContext	context
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
GrpcStreamSubscription()

Method Summary

Modifier and Type	Method and Description
boolean	isUnsubscribed() Return whether it's been unsubscribed or not.
void	unsubscribe() UnSubscribe current subscription.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final transient org.slf4j.Logger logger

context

protected final io.grpc.Context.CancellableContext context

Constructor Detail

GrpcStreamSubscription

public GrpcStreamSubscription()

Method Detail

unsubscribe

public void unsubscribe()

Description copied from interface: Subscription

UnSubscribe current subscription. This method is thread-safe.

Specified by:

unsubscribe in interface Subscription<T>

isUnsubscribed

public boolean isUnsubscribed()

Description copied from interface: Subscription

Return whether it's been unsubscribed or not.

Specified by:

isUnsubscribed in interface Subscription<T>

Returns:

an subscription status