Agera 入门

Agera 入门

Agera是什么？

Agera(瑞典文的意思是”采取行动”)是一个超轻量级的Android库，帮助Android应用中有生命周期的组件(比如:Activities)或者组件中的对象(比如:Views)预准备数据。 通过加入函数式响应式编程，Agera可以在 什么时机, 什么线程 和 什么数据 层面上更清晰的分离数据处理流程，并且使用一个接近自然语言的单个表达式就能编写一个复杂的异步流。

怎用用Agera？

一个特意写的例子,请求一个图片显示在背景上面

public class AgeraActivity extends Activityimplements Receiver<Bitmap>, Updatable {private static final ExecutorService NETWORK_EXECUTOR =newSingleThreadExecutor();private static final ExecutorService DECODE_EXECUTOR =newSingleThreadExecutor();private static final String BACKGROUND_BASE_URL ="http://www.gravatar.com/avatar/4df6f4fe5976df17deeea19443d4429d?s=";private Repository<Result<Bitmap>> background;private ImageView backgroundView;@Overrideprotected void onCreate(final Bundle savedInstanceState) {super.onCreate(savedInstanceState);// Set the content viewsetContentView(R.layout.activity_main);// Find the background viewbackgroundView = (ImageView) findViewById(R.id.background);// 创建一个repository： 包括一个图片请求。Initially// 初始值：absent, 配置通过网络获取屏幕大小的图片。background = repositoryWithInitialValue(Result.<Bitmap>absent()).observe() // 在这个例子中不需要刷新背景图，也就是不需要被观察者.onUpdatesPerLoop() // 在这个例子中每次都更新.getFrom(new Supplier<HttpRequest>() {@NonNull@Overridepublic HttpRequest get() {DisplayMetrics displayMetrics = getResources().getDisplayMetrics();int size = Math.max(displayMetrics.heightPixels,displayMetrics.widthPixels);return httpGetRequest(BACKGROUND_BASE_URL + size).compile();}}) // 实现带有显示大小参数的Http请求.goTo(NETWORK_EXECUTOR) // 设置网络请求线程.attemptTransform(httpFunction()).orSkip() // 设置http请求，如果失败，跳过下面流程.goTo(DECODE_EXECUTOR) // 设置解码线程.thenTransform(new Function<HttpResponse, Result<Bitmap>>() {@NonNull@Overridepublic Result<Bitmap> apply(@NonNull HttpResponse response) {byte[] body = response.getBody();return absentIfNull(decodeByteArray(body, 0, body.length));}}) // 解码图片, 如果失败返回absent.onDeactivation(SEND_INTERRUPT) // 中断线程.compile(); // 创建repository}@Overrideprotected void onResume() {super.onResume();// 注册观察者，激活流程background.addUpdatable(this);}@Overrideprotected void onPause() {super.onPause();// 注销观察者，去激活流程background.removeUpdatable(this);}@Overridepublic void update() {// repository更新时 调用// 如果bitmap有效, 发送到下面的accept()方法background.get().ifSucceededSendTo(this);}@Overridepublic void accept(@NonNull Bitmap background) {// 设置背景图片backgroundView.setImageBitmap(background);}
}

repository的用法

agera提出了Push event,pull data model的想法，这个和Push data model的想法不太相同。agera在只会告诉观察者去update而，update的数据需要观察者自己去数据仓库提取（即Repository）。Agera为我们提供了Repositories来让我萌构建数据仓库，并且提供了getFrom，mergeIn，transform方法对数据进行处理。
复杂的repository可以用单个Java表达式编译出来。
Java表达式由下面几部分构成，顺序如下：

// 声明RepositoryCompiler，并初始化，返回REventSource实例;
1. Repositories.repositoryWithInitialValue(...);
// 指定事件源(Observable)，可以多个，返回RFrequency实例;
2. Event sources - .observe(...);
// 设置通知频率(比如click频率限制)，返回RFlow实例;
3. Frequency of reaction - .onUpdatesPer(...) or .onUpdatesPerLoop();
// 设置数据源(Supplier)，返回RFlow或RTermination实例;
4. Data processing flow - .getFrom(...), .mergeIn(...), .transform(...), etc.;
// 其他配置，返回RConfig;
5. Miscellaneous configurations - .notifyIf(...), .onDeactivation(...), etc.;
// 编译成Repository实例。
6. .compile().

我们在看一个Repository的例子：

private Supplier<String> strSupplier = new Supplier<String>() {@NonNull@Overridepublic String get() {return "value";}
};private Function<String,String> transform = new Function<String, String>() {@NonNull@Overridepublic String apply(@NonNull String input) {return "new " + input;}
};private Supplier<Integer> integerSupplier = new Supplier<Integer>() {@NonNull@Overridepublic Integer get() {return 100;}
};private Merger<String,Integer,String> merger = new Merger<String, Integer, String>() {@NonNull@Overridepublic String merge(@NonNull String s, @NonNull Integer integer) {return s + "plus " + String.valueOf(integer);}
};private Updatable updatable = new Updatable() {@Overridepublic void update() {Log.d("TAG", repository.get());}};repository = Repositories.repositoryWithInitialValue("default").observe().onUpdatesPerLoop().getFrom(strSupplier).transform(transform).thenMergeIn(integerSupplier,merger).compile();repository.addUpdatable(updatable);

这个例子最后输出是 new value plus 100;分别做了一次设置，一次转换，和一次合并。当然Agera更强的是对异步线程的操作。我们经常会遇到两个请求先后的问题。Agera可以很好的解决这种问题

private Executor executor1 = Executors.newSingleThreadExecutor();
private Executor executor2 = Executors.newSingleThreadExecutor();
repository = Repositories.repositoryWithInitialValue("default").observe().onUpdatesPerLoop().goTo(executor1).thenGetFrom(new Supplier<Object>() {@NonNull@Overridepublic Object get() {//some biz work,may be block the main thread.return null;}}).goto(exector2).transform(new Function<Object,Object>(){public String apply(@NonNull String input) {return null;}}.compile();

Agera作为类似Rxjava的一套框架虽然没有Rxjava那种量级的方法数，但也是功能十分强大的，今天这些只是讲它最基础的一些用发，相当入门。