Class StreamCodecsKt

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
    • Field Summary

      Fields 
      Modifier and Type Field Description
    • Constructor Summary

      Constructors 
      Constructor Description
    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
    • Method Summary

      Modifier and Type Method Description
      final static <B extends ByteBuf, V extends Any, C extends Collection<V>> StreamCodec<B, C> toCollection(StreamCodec<B, V> $self, Function1<Integer, C> factory)
      final static <B extends ByteBuf, V extends Any> StreamCodec<B, List<V>> listOf(StreamCodec<B, V> $self)
      final static <B extends ByteBuf, V extends Any> StreamCodec<B, Set<V>> setOf(StreamCodec<B, V> $self)
      final static <B extends ByteBuf, V extends Any> StreamCodec<B, Optional<V>> toOptional(StreamCodec<B, V> $self)
      final static <B extends ByteBuf, V extends Any> StreamCodec<B, V> recover(StreamCodec<B, V> $self, Function1<Throwable, V> onFailure)
      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • toCollection

         final static <B extends ByteBuf, V extends Any, C extends Collection<V>> StreamCodec<B, C> toCollection(StreamCodec<B, V> $self, Function1<Integer, C> factory)
        Since:

        0.16.0

      • listOf

         final static <B extends ByteBuf, V extends Any> StreamCodec<B, List<V>> listOf(StreamCodec<B, V> $self)
        Since:

        0.16.0

      • setOf

         final static <B extends ByteBuf, V extends Any> StreamCodec<B, Set<V>> setOf(StreamCodec<B, V> $self)
        Since:

        0.16.0

      • toOptional

         final static <B extends ByteBuf, V extends Any> StreamCodec<B, Optional<V>> toOptional(StreamCodec<B, V> $self)
        Since:

        0.16.0

      • recover

         final static <B extends ByteBuf, V extends Any> StreamCodec<B, V> recover(StreamCodec<B, V> $self, Function1<Throwable, V> onFailure)
        Since:

        0.16.0