Class ShardingQueries.ShardsQueryResult$

  • All Implemented Interfaces:
    java.io.Serializable
    Enclosing class:
    ShardingQueries

    public static class ShardingQueries.ShardsQueryResult$
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <B> ShardingQueries.ShardsQueryResult<B> apply​(scala.collection.immutable.Seq<scala.util.Either<java.lang.String,​B>> ps, int total, scala.concurrent.duration.FiniteDuration timeout)  
      <B> ShardingQueries.ShardsQueryResult<B> apply​(scala.collection.immutable.Set<java.lang.String> failed, scala.collection.immutable.Seq<B> responses, int total, scala.concurrent.duration.FiniteDuration timeout)  
      <T,​A,​B>
      scala.Tuple2<scala.collection.immutable.Seq<A>,​scala.collection.immutable.Seq<B>>
      partition​(scala.collection.immutable.Seq<T> ps, scala.Function1<T,​scala.util.Either<A,​B>> f)  
      <A,​B>
      scala.Tuple2<scala.collection.immutable.Seq<A>,​scala.collection.immutable.Seq<B>>
      prepend​(scala.Tuple2<scala.collection.immutable.Seq<A>,​scala.collection.immutable.Seq<B>> acc, scala.util.Either<A,​B> next)  
      <B> scala.Option<scala.Tuple4<scala.collection.immutable.Set<java.lang.String>,​scala.collection.immutable.Seq<B>,​java.lang.Object,​scala.concurrent.duration.FiniteDuration>> unapply​(ShardingQueries.ShardsQueryResult<B> x$0)  
      • Methods inherited from class java.lang.Object

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

      • ShardsQueryResult$

        public ShardsQueryResult$()
    • Method Detail

      • apply

        public <B> ShardingQueries.ShardsQueryResult<B> apply​(scala.collection.immutable.Seq<scala.util.Either<java.lang.String,​B>> ps,
                                                              int total,
                                                              scala.concurrent.duration.FiniteDuration timeout)
        Parameters:
        ps - the partitioned results of actors queried that did not reply by the timeout or returned another failure and those that did
        total - the total number of actors tracked versus a possible subset
        timeout - (undocumented)
        Returns:
        (undocumented)
      • partition

        public <T,​A,​B> scala.Tuple2<scala.collection.immutable.Seq<A>,​scala.collection.immutable.Seq<B>> partition​(scala.collection.immutable.Seq<T> ps,
                                                                                                                                     scala.Function1<T,​scala.util.Either<A,​B>> f)
      • prepend

        public <A,​B> scala.Tuple2<scala.collection.immutable.Seq<A>,​scala.collection.immutable.Seq<B>> prepend​(scala.Tuple2<scala.collection.immutable.Seq<A>,​scala.collection.immutable.Seq<B>> acc,
                                                                                                                           scala.util.Either<A,​B> next)
      • apply

        public <B> ShardingQueries.ShardsQueryResult<B> apply​(scala.collection.immutable.Set<java.lang.String> failed,
                                                              scala.collection.immutable.Seq<B> responses,
                                                              int total,
                                                              scala.concurrent.duration.FiniteDuration timeout)
      • unapply

        public <B> scala.Option<scala.Tuple4<scala.collection.immutable.Set<java.lang.String>,​scala.collection.immutable.Seq<B>,​java.lang.Object,​scala.concurrent.duration.FiniteDuration>> unapply​(ShardingQueries.ShardsQueryResult<B> x$0)