ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [43/50] [abbrv] incubator-ignite git commit: IGNITE-142 Rename IgniteAsyncSupport.enableAsync() to IgniteAsyncSupport.withAsync()
Date Wed, 28 Jan 2015 12:35:29 GMT
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-6
Commit: 4a92912120dce0c9969e55daf0a882786fe160b9
Parents: 74e24c6
Author: sevdokimov <sevdokimov@gridgain.com>
Authored: Wed Jan 28 14:50:54 2015 +0300
Committer: sevdokimov <sevdokimov@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)
 


Mime
View raw message