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 akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> |
logByteString(java.lang.String name,
int maxBytes) |
static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.NotUsed> |
logByteStringBidi(java.lang.String name,
int maxBytes) |
static akka.stream.scaladsl.BidiFlow<akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsInbound,akka.NotUsed> |
logTLSBidi(java.lang.String name,
int maxBytes) |
static akka.stream.scaladsl.BidiFlow<akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsInbound,java.lang.Object> |
logTLSBidiBySetting(java.lang.String tag,
scala.Option<java.lang.Object> maxBytesSetting) |
static akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsInbound,akka.NotUsed> |
logTlsInbound(java.lang.String name,
int maxBytes) |
static akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsOutbound,akka.NotUsed> |
logTlsOutbound(java.lang.String name,
int maxBytes) |
static <A> akka.stream.scaladsl.Flow<A,A,akka.NotUsed> |
logToString(java.lang.String name,
int maxBytes) |
static <A,B> akka.stream.scaladsl.BidiFlow<A,A,B,B,akka.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(akka.util.ByteString bytes,
int maxBytes) |
public static int MaxBytesPrinted()
public static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.NotUsed> logByteStringBidi(java.lang.String name, int maxBytes)
public static <A,B> akka.stream.scaladsl.BidiFlow<A,A,B,B,akka.NotUsed> logToStringBidi(java.lang.String name, int maxBytes, scala.reflect.ClassTag<A> evidence$1, scala.reflect.ClassTag<B> evidence$2)
public static akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> logByteString(java.lang.String name, int maxBytes)
public static <A> akka.stream.scaladsl.Flow<A,A,akka.NotUsed> logToString(java.lang.String name, int maxBytes)
public static akka.stream.scaladsl.BidiFlow<akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsInbound,akka.NotUsed> logTLSBidi(java.lang.String name, int maxBytes)
public static akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsOutbound,akka.NotUsed> logTlsOutbound(java.lang.String name, int maxBytes)
public static akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsInbound,akka.NotUsed> logTlsInbound(java.lang.String name, int maxBytes)
public static java.lang.String printByteString(akka.util.ByteString bytes, int maxBytes)
public static akka.stream.scaladsl.BidiFlow<akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsInbound,java.lang.Object> logTLSBidiBySetting(java.lang.String tag, scala.Option<java.lang.Object> maxBytesSetting)