Package akka.cluster.sharding
Class ShardingQueries.ShardsQueryResult$
- java.lang.Object
-
- akka.cluster.sharding.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
-
-
Field Summary
Fields Modifier and Type Field Description static ShardingQueries.ShardsQueryResult$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description ShardsQueryResult$()
-
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)
-
-
-
Field Detail
-
MODULE$
public static final ShardingQueries.ShardsQueryResult$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
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 didtotal
- the total number of actors tracked versus a possible subset
-
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)
-
-