Mailing-List: contact dev-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@ignite.apache.org
MIME-Version: 1.0
References: <CAAJdKXmb84q67ym+yWm+05KXy2SSw8r9HqmE3mDhZ2_2A3DQwg@mail.gmail.com>
 <CAKdXNOXg1ywt04k11XyYM8a8H-HRHmJ_tMBQUkwtytzNakAjtw@mail.gmail.com>
 <CAAJdKXmLaxktRqozK3Ldso64kupbGwSXB91vL20P8dighEwnRg@mail.gmail.com>
 <CAKdXNOVgqOCV-3R8SLTjHNRsgg8hpEob9B4xAE0jw=A3Bw1H_Q@mail.gmail.com>
 <CAAJdKXkRi-npPknnAGAs5SBfeyOvin3ccuuhEOaajYt4s7ypKg@mail.gmail.com> <CABDss3hixO-gKHve-msqDa8fGzs7Jjh+dSzKmDGJM3oYs+dGTA@mail.gmail.com>
In-Reply-To: <CABDss3hixO-gKHve-msqDa8fGzs7Jjh+dSzKmDGJM3oYs+dGTA@mail.gmail.com>
From: Sergei Egorov <bsideup@gmail.com>
Date: Mon, 27 Mar 2017 13:14:22 +0000
Message-ID: <CAAJdKX=bN+4Dnbc47M10dyZanfLsDWAiAnd1b39Vu9bvUiY-xQ@mail.gmail.com>
Subject: Re: IgniteFuture adapters
To: dev@ignite.apache.org
Content-Type: multipart/alternative; boundary=001a1143f990c8d9a4054bb61f54
archived-at: Mon, 27 Mar 2017 13:20:57 -0000

--001a1143f990c8d9a4054bb61f54
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

True, I just prefer functional style over static methods.

Regarding "why should this method be a part of the future API" - why not?
It helps to chain such calls instead of call nesting.

Of course, if Java had extension methods it wouldn't be needed, but we
don't have them.

On Mon, Mar 27, 2017 at 4:06 PM Alexey Goncharuk <alexey.goncharuk@gmail.co=
m>
wrote:

> Sergei,
>
> Why should this method be a part of the future API? The only implementati=
on
> will do "return func(this);"
>
> I can achieve the same result the following way:
> rx(compute.runAsync(runnable)).timeout(5_000).subscribe();
>
>
>
> 2017-03-27 15:54 GMT+03:00 Sergei Egorov <bsideup@gmail.com>:
>
> > Take a look at my initial code.
> >
> > public <T> IgniteFuture<T> chain(IgniteClosure<? super
> > IgniteFuture<V>, T> doneCb);
> >
> > vs
> >
> > public <R> R to(IgniteClosure<? super IgniteFuture<V>, R> transformer);
> >
> >
> > The result of "chain" is IgniteFuture.
> >
> > The result of "to" is the object returned from transformer. It would
> > be CompletableFuture, Rx's Observable, Reactor's Mono, etc...
> >
> >
> > On Mon, Mar 27, 2017 at 3:18 PM =D0=94=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=
=B9 =D0=A0=D1=8F=D0=B1=D0=BE=D0=B2 <somefireone@gmail.com>
> > wrote:
> >
> > > Em... When you get result of your future, closure will produce new
> future
> > > with completely different type.
> > >
> > > 2017-03-27 13:43 GMT+03:00 Sergei Egorov <bsideup@gmail.com>:
> > >
> > > > It doesn't :)
> > > >
> > > > It returns another IgniteFuture where I want to transform it to
> > > completely
> > > > different type.
> > > >
> > > > On Mon, Mar 27, 2017 at 1:41 PM =D0=94=D0=BC=D0=B8=D1=82=D1=80=D0=
=B8=D0=B9 =D0=A0=D1=8F=D0=B1=D0=BE=D0=B2 <somefireone@gmail.com
> >
> > > > wrote:
> > > >
> > > > > IgniteFuture have method
> > > > >
> > > > > public <T> IgniteFuture<T> chain(IgniteClosure<? super
> > IgniteFuture<V>,
> > > > T>
> > > > > doneCb);
> > > > >
> > > > > which do this.
> > > > >
> > > > > 2017-03-27 13:30 GMT+03:00 Sergei Egorov <bsideup@gmail.com>:
> > > > >
> > > > > > Hi!
> > > > > >
> > > > > > Would be nice if igniteFuture would provide a small but very
> usable
> > > > > method:
> > > > > >
> > > > > >     public <R> R to(Function<IgniteFuture<T>, R> transformer)
> > > > > >
> > > > > > it will allow to chain it like:
> > > > > >
> > > > > >
>  compute.runAsync(runnable).to(rx()).timeout(5_000).subscribe()
> > > > > >
> > > > > > Where rx() is just a static function with something like:
> > > > > >
> > > > > >    public static <T> Function<IgniteFuture<T>, Observable<T>>
> rx()
> > > > > >
> > > > > >
> > > > > > WDYT?
> > > > > >
> > > > >
> > > > >
> > > > > 2017-03-27 13:30 GMT+03:00 Sergei Egorov <bsideup@gmail.com>:
> > > > >
> > > > > > Hi!
> > > > > >
> > > > > > Would be nice if igniteFuture would provide a small but very
> usable
> > > > > method:
> > > > > >
> > > > > >     public <R> R to(Function<IgniteFuture<T>, R> transformer)
> > > > > >
> > > > > > it will allow to chain it like:
> > > > > >
> > > > > >
>  compute.runAsync(runnable).to(rx()).timeout(5_000).subscribe()
> > > > > >
> > > > > > Where rx() is just a static function with something like:
> > > > > >
> > > > > >    public static <T> Function<IgniteFuture<T>, Observable<T>>
> rx()
> > > > > >
> > > > > >
> > > > > > WDYT?
> > > > > >
> > > > >
> > > >
> > >
> >
>

--001a1143f990c8d9a4054bb61f54--