public class LogByteStringTools
extends java.lang.Object
Flow and BidiFlow stages to log streams of ByteString.
Constructor and Description |
---|
LogByteStringTools() |
Modifier and Type | Method and Description |
---|---|
static char |
asASCII(byte b) |
static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> |
logByteString(java.lang.String name,
int maxBytes) |
static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> |
logByteStringBidi(java.lang.String name,
int maxBytes) |
static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.NotUsed> |
logTLSBidi(java.lang.String name,
int maxBytes) |
static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,java.lang.Object> |
logTLSBidiBySetting(java.lang.String tag,
scala.Option<java.lang.Object> maxBytesSetting) |
static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.NotUsed> |
logTlsInbound(java.lang.String name,
int maxBytes) |
static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.NotUsed> |
logTlsOutbound(java.lang.String name,
int maxBytes) |
static <A> org.apache.pekko.stream.scaladsl.Flow<A,A,org.apache.pekko.NotUsed> |
logToString(java.lang.String name,
int maxBytes) |
static <A,B> org.apache.pekko.stream.scaladsl.BidiFlow<A,A,B,B,org.apache.pekko.NotUsed> |
logToStringBidi(java.lang.String name,
int maxBytes,
scala.reflect.ClassTag<A> evidence$1,
scala.reflect.ClassTag<B> evidence$2) |
static int |
MaxBytesPrinted() |
static java.lang.String |
printByteString(org.apache.pekko.util.ByteString bytes,
int maxBytes,
boolean addPrefix,
java.lang.String indent) |
public static int MaxBytesPrinted()
public static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> logByteStringBidi(java.lang.String name, int maxBytes)
public static <A,B> org.apache.pekko.stream.scaladsl.BidiFlow<A,A,B,B,org.apache.pekko.NotUsed> logToStringBidi(java.lang.String name, int maxBytes, scala.reflect.ClassTag<A> evidence$1, scala.reflect.ClassTag<B> evidence$2)
public static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> logByteString(java.lang.String name, int maxBytes)
public static <A> org.apache.pekko.stream.scaladsl.Flow<A,A,org.apache.pekko.NotUsed> logToString(java.lang.String name, int maxBytes)
public static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.NotUsed> logTLSBidi(java.lang.String name, int maxBytes)
public static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.NotUsed> logTlsOutbound(java.lang.String name, int maxBytes)
public static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.NotUsed> logTlsInbound(java.lang.String name, int maxBytes)
public static java.lang.String printByteString(org.apache.pekko.util.ByteString bytes, int maxBytes, boolean addPrefix, java.lang.String indent)
public static char asASCII(byte b)
public static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,java.lang.Object> logTLSBidiBySetting(java.lang.String tag, scala.Option<java.lang.Object> maxBytesSetting)