Class LogByteStringTools


  • public class LogByteStringTools
    extends java.lang.Object
    INTERNAL API

    Flow and BidiFlow stages to log streams of ByteString.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static char asASCII​(byte b)  
      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, boolean addPrefix, java.lang.String indent)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • LogByteStringTools

        public LogByteStringTools()
    • Method Detail

      • MaxBytesPrinted

        public static int MaxBytesPrinted()
      • logByteStringBidi

        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)
      • logToStringBidi

        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)
      • logByteString

        public static akka.stream.scaladsl.Flow<akka.util.ByteString,​akka.util.ByteString,​akka.NotUsed> logByteString​(java.lang.String name,
                                                                                                                                  int maxBytes)
      • logToString

        public static <A> akka.stream.scaladsl.Flow<A,​A,​akka.NotUsed> logToString​(java.lang.String name,
                                                                                              int maxBytes)
      • logTLSBidi

        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)
      • logTlsOutbound

        public static akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsOutbound,​akka.stream.TLSProtocol.SslTlsOutbound,​akka.NotUsed> logTlsOutbound​(java.lang.String name,
                                                                                                                                                                       int maxBytes)
      • logTlsInbound

        public static akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,​akka.stream.TLSProtocol.SslTlsInbound,​akka.NotUsed> logTlsInbound​(java.lang.String name,
                                                                                                                                                                    int maxBytes)
      • printByteString

        public static java.lang.String printByteString​(akka.util.ByteString bytes,
                                                       int maxBytes,
                                                       boolean addPrefix,
                                                       java.lang.String indent)
      • asASCII

        public static char asASCII​(byte b)
      • logTLSBidiBySetting

        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)