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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static voidclear()static SagaStatusUpdateObservergetInstance()static SagaStatusUpdateObserverinitialize(java.util.function.Consumer<SagaStatusUpdateObserver> resubscribe)voidonCompleted()voidonError(java.lang.Throwable t)voidonNext(games.mythical.saga.sdk.proto.streams.StatusUpdate message)SagaStatusUpdateObserverwith(SagaCurrencyExecutor sagaCurrencyExecutor)SagaStatusUpdateObserverwith(SagaItemExecutor sagaItemExecutor)SagaStatusUpdateObserverwith(SagaItemTypeExecutor sagaItemTypeExecutor)SagaStatusUpdateObserverwith(SagaMetadataExecutor sagaMetadataExecutor)SagaStatusUpdateObserverwith(SagaPlayerWalletExecutor sagaPlayerWalletExecutor)SagaStatusUpdateObserverwith(SagaReservationExecutor sagaReservationExecutor)-
Methods inherited from class games.mythical.saga.sdk.client.observer.AbstractObserver
resetConnectionRetry, sleepBetweenReconnects
-
-
-
-
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()
-
-