IGNITE-142 Rename IgniteAsyncSupport.enableAsync() to IgniteAsyncSupport.withAsync()
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4a929121 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4a929121 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4a929121 Branch: refs/heads/ignite-132 Commit: 4a92912120dce0c9969e55daf0a882786fe160b9 Parents: 74e24c6 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Wed Jan 28 14:50:54 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Wed Jan 28 14:50:54 2015 +0300 ---------------------------------------------------------------------- .../ignite/scalar/examples/ScalarContinuationExample.scala | 2 +- .../apache/ignite/scalar/pimps/ScalarProjectionPimp.scala | 8 ++++---- .../ignite/visor/commands/tasks/VisorTasksCommandSpec.scala | 2 +- 3 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4a929121/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala index f3855a3..6ac2b91 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala @@ -114,7 +114,7 @@ class FibonacciClosure ( // Projection that excludes node with id passed in constructor if others exists. val prj = if (grid$.cluster().nodes().size() > 1) grid$.cluster().forOthers(excludeNode) else grid$.cluster().forNode(excludeNode) - val comp = grid$.compute(prj).enableAsync() + val comp = grid$.compute(prj).withAsync() // If future is not cached in node-local store, cache it. // Note recursive grid execution! http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4a929121/modules/scalar/src/main/scala/org/apache/ignite/scalar/pimps/ScalarProjectionPimp.scala ---------------------------------------------------------------------- diff --git a/modules/scalar/src/main/scala/org/apache/ignite/scalar/pimps/ScalarProjectionPimp.scala b/modules/scalar/src/main/scala/org/apache/ignite/scalar/pimps/ScalarProjectionPimp.scala index 7962236..5634ab3 100644 --- a/modules/scalar/src/main/scala/org/apache/ignite/scalar/pimps/ScalarProjectionPimp.scala +++ b/modules/scalar/src/main/scala/org/apache/ignite/scalar/pimps/ScalarProjectionPimp.scala @@ -376,7 +376,7 @@ class ScalarProjectionPimp[A <: ClusterGroup] extends PimpedType[A] with Iterabl */ def callAsync$[R](@Nullable s: Seq[Call[R]], @Nullable p: NF): IgniteFuture[java.util.Collection[R]] = { - val comp = value.ignite().compute(forPredicate(p)).enableAsync() + val comp = value.ignite().compute(forPredicate(p)).withAsync() comp.call[R](toJavaCollection(s, (f: Call[R]) => toCallable(f))) @@ -436,7 +436,7 @@ class ScalarProjectionPimp[A <: ClusterGroup] extends PimpedType[A] with Iterabl * @see `org.apache.ignite.cluster.ClusterGroup.call(...)` */ def runAsync$(@Nullable s: Seq[Run], @Nullable p: NF): IgniteFuture[_] = { - val comp = value.ignite().compute(forPredicate(p)).enableAsync() + val comp = value.ignite().compute(forPredicate(p)).withAsync() comp.run(toJavaCollection(s, (f: Run) => toRunnable(f))) @@ -495,7 +495,7 @@ class ScalarProjectionPimp[A <: ClusterGroup] extends PimpedType[A] with Iterabl def reduceAsync$[R1, R2](s: Seq[Call[R1]], r: Seq[R1] => R2, @Nullable p: NF): IgniteFuture[R2] = { assert(s != null && r != null) - val comp = value.ignite().compute(forPredicate(p)).enableAsync() + val comp = value.ignite().compute(forPredicate(p)).withAsync() comp.call(toJavaCollection(s, (f: Call[R1]) => toCallable(f)), r) @@ -649,7 +649,7 @@ class ScalarProjectionPimp[A <: ClusterGroup] extends PimpedType[A] with Iterabl */ def affinityRunAsync$(cacheName: String, @Nullable affKey: Any, @Nullable r: Run, @Nullable p: NF): IgniteFuture[_] = { - val comp = value.ignite().compute(forPredicate(p)).enableAsync() + val comp = value.ignite().compute(forPredicate(p)).withAsync() comp.affinityRun(cacheName, affKey, toRunnable(r)) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4a929121/modules/visor-console/src/test/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommandSpec.scala ---------------------------------------------------------------------- diff --git a/modules/visor-console/src/test/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommandSpec.scala b/modules/visor-console/src/test/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommandSpec.scala index ae3b71c..897fa39 100644 --- a/modules/visor-console/src/test/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommandSpec.scala +++ b/modules/visor-console/src/test/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommandSpec.scala @@ -46,7 +46,7 @@ class VisorTasksCommandSpec extends FlatSpec with Matchers with BeforeAndAfterAl visor.open(config("grid-visor"), "n/a") try { - val compute = visor.grid.compute().enableAsync + val compute = visor.grid.compute().withAsync compute.withName("TestTask1").execute(new TestTask1(), null)
