Package games.mythical.saga.sdk.client.observer

Class SagaStatusUpdateObserver

java.lang.Object

games.mythical.saga.sdk.client.observer.AbstractObserver<games.mythical.saga.sdk.proto.streams.StatusUpdate>

games.mythical.saga.sdk.client.observer.SagaStatusUpdateObserver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<games.mythical.saga.sdk.proto.streams.StatusUpdate>

public final class SagaStatusUpdateObserver
extends AbstractObserver<games.mythical.saga.sdk.proto.streams.StatusUpdate>

Constructor Summary

Constructors

Constructor	Description
SagaStatusUpdateObserver(java.util.function.Consumer<SagaStatusUpdateObserver> resubscribe)

Method Summary

Modifier and Type	Method	Description
static void	clear()
static SagaStatusUpdateObserver	getInstance()
static SagaStatusUpdateObserver	initialize(java.util.function.Consumer<SagaStatusUpdateObserver> resubscribe)
void	onCompleted()
void	onError(java.lang.Throwable t)
void	onNext(games.mythical.saga.sdk.proto.streams.StatusUpdate message)
SagaStatusUpdateObserver	with(SagaCurrencyExecutor sagaCurrencyExecutor)
SagaStatusUpdateObserver	with(SagaItemExecutor sagaItemExecutor)
SagaStatusUpdateObserver	with(SagaItemTypeExecutor sagaItemTypeExecutor)
SagaStatusUpdateObserver	with(SagaMetadataExecutor sagaMetadataExecutor)
SagaStatusUpdateObserver	with(SagaPlayerWalletExecutor sagaPlayerWalletExecutor)
SagaStatusUpdateObserver	with(SagaReservationExecutor sagaReservationExecutor)

Methods inherited from class games.mythical.saga.sdk.client.observer.AbstractObserver

resetConnectionRetry, sleepBetweenReconnects

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaStatusUpdateObserver

public SagaStatusUpdateObserver(java.util.function.Consumer<SagaStatusUpdateObserver> resubscribe)

Method Detail

getInstance

public static SagaStatusUpdateObserver getInstance()

initialize

public static SagaStatusUpdateObserver initialize(java.util.function.Consumer<SagaStatusUpdateObserver> resubscribe)

clear

public static void clear()

with

public SagaStatusUpdateObserver with(SagaCurrencyExecutor sagaCurrencyExecutor)

with

public SagaStatusUpdateObserver with(SagaItemExecutor sagaItemExecutor)

with

public SagaStatusUpdateObserver with(SagaItemTypeExecutor sagaItemTypeExecutor)

with

public SagaStatusUpdateObserver with(SagaPlayerWalletExecutor sagaPlayerWalletExecutor)

with

public SagaStatusUpdateObserver with(SagaReservationExecutor sagaReservationExecutor)

with

public SagaStatusUpdateObserver with(SagaMetadataExecutor sagaMetadataExecutor)

onNext

public void onNext(games.mythical.saga.sdk.proto.streams.StatusUpdate message)

onError

public void onError(java.lang.Throwable t)

onCompleted

public void onCompleted()