Interface Decoder.InboundCompressionAccess

  • All Known Subinterfaces:
    Decoder.InboundCompressionAccessImpl
    Enclosing class:
    Decoder

    public static interface Decoder.InboundCompressionAccess
    Materialized value of Encoder which allows safely calling into the operator to interfact with compression tables.
    • Method Detail

      • closeCompressionFor

        scala.concurrent.Future<Done> closeCompressionFor​(long originUid)
      • currentCompressionOriginUids

        scala.concurrent.Future<scala.collection.immutable.Set<java.lang.Object>> currentCompressionOriginUids()
        For testing purposes
      • runNextActorRefAdvertisement

        void runNextActorRefAdvertisement()
        For testing purposes, usually triggered by timer from within Decoder operator.
      • runNextClassManifestAdvertisement

        void runNextClassManifestAdvertisement()
        For testing purposes, usually triggered by timer from within Decoder operator.