Package com.eventstore.dbclient

Interface StreamConsumer

public interface StreamConsumer

  • Method Details

    • onSubscribe

      default void onSubscribe(org.reactivestreams.Subscription subscription)

    • onEvent

      void onEvent(ResolvedEvent event)

    • onSubscriptionConfirmation

      void onSubscriptionConfirmation(String subscriptionId)

    • onCheckpoint

      void onCheckpoint(long commit, long prepare)

    • onStreamNotFound

      void onStreamNotFound(String streamName)

    • onFirstStreamPosition

      void onFirstStreamPosition(long position)

    • onLastStreamPosition

      void onLastStreamPosition(long position)

    • onLastAllStreamPosition

      void onLastAllStreamPosition(long commit, long prepare)

    • onCaughtUp

      void onCaughtUp()

    • onFellBehind

      void onFellBehind()

    • onCancelled

      void onCancelled(Throwable exception)

    • onComplete

      void onComplete()