Package com.here.platform.data.client.utils

Class ResilientSource

java.lang.Object
com.here.platform.data.client.utils.ResilientSource
public class ResilientSource extends Object

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static interface 
    ResilientSource.NonRetriableException
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ResilientSource()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>
    withRetries(String description, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,Object> originSource, scala.Function1<Object,org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>> fallbackTo, org.apache.pekko.event.LoggingAdapter log)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ResilientSource

      public ResilientSource()

  • Method Details

    • withRetries

      public static org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> withRetries(String description, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,Object> originSource, scala.Function1<Object,org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>> fallbackTo, org.apache.pekko.event.LoggingAdapter log)