ByteStringSinkProbe

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`cancel()`
`void`	`ensureSubscription()`
`int`	`expectByte()`
`void`	`expectBytes(org.apache.pekko.util.ByteString expected)`
`org.apache.pekko.util.ByteString`	`expectBytes(int length)`
`void`	`expectComplete()`
`java.lang.Throwable`	`expectError()`
`void`	`expectError(java.lang.Throwable cause)`
`void`	`expectNoBytes()`
`void`	`expectNoBytes(scala.concurrent.duration.FiniteDuration timeout)`
`void`	`expectSubscriptionAndComplete()`
`void`	`expectUtf8EncodedString(java.lang.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)`

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

org.apache.pekko.util.ByteString expectBytes(int length)

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

void expectUtf8EncodedString(java.lang.String string)

void expectNoBytes(scala.concurrent.duration.FiniteDuration timeout)

void expectError(java.lang.Throwable cause)

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

Interface ByteStringSinkProbe