Android Agera 框架简单使用

Agera响应式框架

Agera框架由google推出,是一个响应式编程的框架

Agera is a set of classes and interfaces to help write functional, asynchronous, >and reactive applications for Android.
Requires Android SDK version 9 or higher. — github

使用Gradle 添加依赖

compile 'com.google.android.agera:agera:1.0.0-rc2'

先了解下函数响应式编程

函数响应式编程是在观察者模式的基础上，增加对Observables发送的数据流进行操纵和变换的功能。

观察者模式

一个Observable和一个或者多个Observers。Observable发送事件，而Observer订阅和接收这些事件。

Agera关键类

• Observable：Agera中的被观察者，用于在合适的时机去通知观察者进行更新。

• Updatable：Agera中的观察者，用于观察Observable。

• Supplier：Agera中提供数据的接口，通过范型指定数据类型，通过get()方法获取数据。

• Repository：Agera中集成了Observable和Supplier功能的一个［提供数据的被观察者］。

下面逐一讲解使用.

简单的应用,只使用Updateable观察者更新UI

布局文件就不给了,非常简单,一个Button, 一个TextView

// updateable是观察者模式的观察者
public class MainActivity extends AppCompatActivity implements Updatable {private TextView mTvText;private Button mBtnUpdate;// 创建一个被观察者用于更新事件private Observable observable = new Observable() {@Overridepublic void addUpdatable(Updatable updatable) {updatable.update();}@Overridepublic void removeUpdatable(Updatable updatable) {}};@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);initView();}private void initView() {mTvText = (TextView) findViewById(R.id.id_tv_show);mBtnUpdate = (Button) findViewById(R.id.id_btn_update);mBtnUpdate.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {// 添加观察者observable.addUpdatable(MainActivity.this);}});}// 观察者更新事件@Overridepublic void update() {mTvText.setText("update by button");}
}

效果

注意:此处没有进行数据传递,传递数据需使用Repository类

Repository是一个被观察者,同时实现了提供数据的接口,通过签名即可看到.
public interface Repository extends Observable, Supplier {}

带有数据交互的观察者

使用Repository实例获取带有数据交互的被观察者,数据从supplier接口中获取.

public class MainActivity extends AppCompatActivity implements Updatable {private TextView mTvText;private Button mBtnUpdate;private Supplier<String> supplier = new Supplier<String>() {@NonNull@Overridepublic String get() {return "supplier!";}};private Repository<String> repository = Repositories.repositoryWithInitialValue("Default") // 生成repository,并赋默认值.observe() // 表示事件开始.onUpdatesPerLoop() // 规定事件发生的频率.thenGetFrom(supplier) // 从supplier中获取数据.compile(); // 得到实例@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);initView();}private void initView() {mTvText = (TextView) findViewById(R.id.id_tv_show);mBtnUpdate = (Button) findViewById(R.id.id_btn_update);mBtnUpdate.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {// 添加观察者repository.addUpdatable(MainActivity.this);}});}// 观察者更新事件@Overridepublic void update() {mTvText.setText(repository.get());}
}

简单的先介绍到这里，随后会写一篇demo