Package com.singularsys.jeptests.unit.misc

# Class PublishingVariableTest.BasicSubscriber

java.lang.Object
com.singularsys.jeptests.unit.misc.PublishingVariableTest.BasicSubscriber

All Implemented Interfaces:
  `Flow.Subscriber<VariableTableAction>`

Enclosing class:
  `PublishingVariableTest`

public class PublishingVariableTest.BasicSubscriber extends Object implements Flow.Subscriber<VariableTableAction>
A basic subscriber. When the `onNext(VariableTableAction)` method is called, it adds a item to `messages`.

- ## Field Summary

  Fields
  Modifier and Type
  Field
  Description
  `final LinkedBlockingQueue<String>`
  `messages`

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `BasicSubscriber()`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `cancel()`
  `void`
  `onComplete()`
  `void`
  `onError(Throwable throwable)`
  `void`
  `onNext(VariableTableAction item)`
  `void`
  `onSubscribe(Flow.Subscription subscription)`

  ### Methods inherited from class java.lang.Object

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

- ## Field Details

  - ### messages

    public final LinkedBlockingQueue<String> messages

- ## Constructor Details

  - ### BasicSubscriber

    public BasicSubscriber()

- ## Method Details

  - ### onSubscribe

    public void onSubscribe(Flow.Subscription subscription)
    Specified by:
      `onSubscribe` in interface `Flow.Subscriber<VariableTableAction>`

  - ### onNext

    public void onNext(VariableTableAction item)
    Specified by:
      `onNext` in interface `Flow.Subscriber<VariableTableAction>`

  - ### onError

    public void onError(Throwable throwable)
    Specified by:
      `onError` in interface `Flow.Subscriber<VariableTableAction>`

  - ### onComplete

    public void onComplete()
    Specified by:
      `onComplete` in interface `Flow.Subscriber<VariableTableAction>`

  - ### cancel

    public void cancel()