ByteStringSinkProbe

public interface ByteStringSinkProbe

INTERNAL API

Method Summary

Modifier and Type

Method

Description

void

cancel()

void

ensureSubscription()

int

expectByte()

org.apache.pekko.util.ByteString

expectBytes(int length)

void

expectBytes(org.apache.pekko.util.ByteString expected)

void

expectComplete()

Throwable

expectError()

void

expectError(Throwable cause)

void

expectNoBytes()

void

expectNoBytes(scala.concurrent.duration.FiniteDuration timeout)

void

expectSubscriptionAndComplete()

void

expectUtf8EncodedString(String string)

void

request(long n)

org.apache.pekko.stream.scaladsl.Sink<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>

sink()

<T> T

within(scala.concurrent.duration.FiniteDuration max, scala.Function0<T> f)

Method Details
- sink
  
  org.apache.pekko.stream.scaladsl.Sink<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> sink()
- expectByte
  
  int expectByte()
- expectBytes
  
  org.apache.pekko.util.ByteString expectBytes(int length)
- expectBytes
  
  void expectBytes(org.apache.pekko.util.ByteString expected)
- expectUtf8EncodedString
  
  void expectUtf8EncodedString(String string)
- expectNoBytes
  
  void expectNoBytes()
- expectNoBytes
  
  void expectNoBytes(scala.concurrent.duration.FiniteDuration timeout)
- expectSubscriptionAndComplete
  
  void expectSubscriptionAndComplete()
- expectComplete
  
  void expectComplete()
- expectError
  
  Throwable expectError()
- expectError
  
  void expectError(Throwable cause)
- ensureSubscription
  
  void ensureSubscription()
- request
  
  void request(long n)
- cancel
  
  void cancel()
- within
  
  <T> T within(scala.concurrent.duration.FiniteDuration max, scala.Function0<T> f)