TestSubscriber.Probe

java.lang.Object
- akka.stream.testkit.TestSubscriber.ManualProbe<T>
- - akka.stream.testkit.TestSubscriber.Probe<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Enclosing class:

TestSubscriber
```
public static class TestSubscriber.Probe<T>
extends TestSubscriber.ManualProbe<T>
```

Constructor Summary

Constructors
Constructor Description

Probe(ActorSystem system)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`TestSubscriber.Probe<T>`	`cancel()`
`TestSubscriber.Probe<T>`	`ensureSubscription()`	Asserts that a subscription has been received or will be received
`TestSubscriber.Probe<T>`	`request(long n)`
`T`	`requestNext()`	Request and expect a stream element.
`T`	`requestNext(scala.concurrent.duration.FiniteDuration d)`	Request and expect a stream element during the specified time or timeout.
`TestSubscriber.Probe<T>`	`requestNext(T element)`	Request and expect a stream element.

Methods inherited from class akka.stream.testkit.TestSubscriber.ManualProbe
expectComplete, expectError, expectError, expectEvent, expectEvent, expectEvent, expectEventPF, expectEventWithTimeoutPF, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNextChainingPF, expectNextChainingPF, expectNextN, expectNextN, expectNextOrComplete, expectNextOrComplete, expectNextOrError, expectNextOrError, expectNextPF, expectNextUnordered, expectNextUnordered, expectNextUnorderedN, expectNextWithTimeoutPF, expectNoMessage, expectNoMessage, expectNoMsg, expectNoMsg, expectSubscription, expectSubscriptionAndComplete, expectSubscriptionAndComplete, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, onComplete, onError, onNext, onSubscribe, receiveWhile, receiveWhile$default$1, receiveWhile$default$2, receiveWhile$default$3, receiveWithin, receiveWithin$default$2, toStrict, within, within

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - Probe
```
public Probe(ActorSystem system)
```
- Method Detail
  - cancel
```
public TestSubscriber.Probe<T> cancel()
```
  - ensureSubscription
```
public TestSubscriber.Probe<T> ensureSubscription()
```
    Asserts that a subscription has been received or will be received
  - request
```
public TestSubscriber.Probe<T> request(long n)
```
  - requestNext
```
public TestSubscriber.Probe<T> requestNext(T element)
```
    Request and expect a stream element.
    
    Parameters:
    
    element - (undocumented)
    
    Returns:
    
    (undocumented)
  - requestNext
```
public T requestNext()
```
    Request and expect a stream element.
    
    Returns:
    
    (undocumented)
  - requestNext
```
public T requestNext(scala.concurrent.duration.FiniteDuration d)
```
    Request and expect a stream element during the specified time or timeout.
    
    Parameters:
    
    d - (undocumented)
    
    Returns:
    
    (undocumented)