Package com.here.platform.data.client.base.http.utils

Class Publishers.GenericSubscription.StateActor

java.lang.Object

com.here.platform.data.client.base.http.utils.Publishers.SimpleActor<com.here.platform.data.client.base.http.utils.Publishers.GenericSubscription.Signal>

com.here.platform.data.client.base.http.utils.Publishers.GenericSubscription.StateActor

Enclosing interface:

Publishers.GenericSubscription

public abstract static class Publishers.GenericSubscription.StateActor
extends com.here.platform.data.client.base.http.utils.Publishers.SimpleActor<com.here.platform.data.client.base.http.utils.Publishers.GenericSubscription.Signal>

Constructor Summary

Constructors

Constructor	Description
StateActor(scala.concurrent.ExecutionContext exec)

Method Summary

Modifier and Type	Method	Description
boolean	cancelled()
boolean	finished()
boolean	initiated()
abstract void	onCancel()
abstract scala.Function1<Publishers.GenericSubscription.Extension,scala.runtime.BoxedUnit>	onExtensionSignal()
abstract void	onInit()
abstract void	onRequest()
void	receive(Publishers.GenericSubscription.Extension extension)
long	requested()

Methods inherited from class java.lang.Object

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

Constructor Details

StateActor

public StateActor(scala.concurrent.ExecutionContext exec)

Method Details

cancelled

public boolean cancelled()

finished

public boolean finished()

initiated

public boolean initiated()

onCancel

public abstract void onCancel()

onExtensionSignal

public abstract scala.Function1<Publishers.GenericSubscription.Extension,scala.runtime.BoxedUnit> onExtensionSignal()

onInit

public abstract void onInit()

onRequest

public abstract void onRequest()

receive

public void receive(Publishers.GenericSubscription.Extension extension)

requested

public long requested()