Class TestSubscription

java.lang.Object
com.github.mizosoft.methanol.testing.TestSubscription
All Implemented Interfaces:
Flow.Subscription

public class TestSubscription extends Object implements Flow.Subscription
  • Constructor Details

    • TestSubscription

      public TestSubscription()
  • Method Details

    • request

      public void request(long n)
      Specified by:
      request in interface Flow.Subscription
    • cancel

      public void cancel()
      Specified by:
      cancel in interface Flow.Subscription
    • awaitRequest

      public long awaitRequest()
    • awaitCancellation

      public void awaitCancellation()
    • isCancelled

      public boolean isCancelled()
    • cancellationCount

      public int cancellationCount()
    • requestCount

      public int requestCount()