slepher / async Goto Github PK

-module(remote_module).

-include_lib("erlando/include/do.hrl").

-export([remote_function/0]).

remote_function() ->
    async_m:'>>='(
      async_m:lift_reply(
        do([async_m ||
               async_m:add_message(hello),
               async_m:add_message(world),
               async_m:return(ok)
           ])),
      fun({message, Message}) ->
              async_m:message({formatted_msg, io_lib:format("~p", [Message])});
         (Reply) ->
              async_m:pure_return(Reply)
      end).

PromiseRemote = rpc:call(RemoteNode, remote_module, remote_function, []),
Promise = async_rpc:promise_wait(RemoteNode, PromiseRemote),

Promise = async_rpc:promise_call(RemoteNode, RemoteNode, remote_module, remote_function, []),

Callback = 
  fun({message, {formatted_msg, Msg}}) ->
            io:format("~s~n", [Msg]);
        (A) ->
            A
  end,
async_m:wait_t(Promise, #{callback => Callback}).

Promises = lists:map(fun(N) -> async_m:promise_sleep(1000) end, lists:seq(1, 10)).
async_m:wait(async_m:map_promises(Promises)).