public interface ByteStringSinkProbe
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()
int expectByte()
org.apache.pekko.util.ByteString expectBytes(int length)
void expectBytes(org.apache.pekko.util.ByteString expected)
void expectUtf8EncodedString(java.lang.String string)
void expectNoBytes()
void expectNoBytes(scala.concurrent.duration.FiniteDuration timeout)
void expectSubscriptionAndComplete()
void expectComplete()
java.lang.Throwable expectError()
void expectError(java.lang.Throwable cause)
void ensureSubscription()
void request(long n)
void cancel()
<T> T within(scala.concurrent.duration.FiniteDuration max, scala.Function0<T> f)