@Test
public void testFetchAddressList() {

    List<Address> list = Flowable.fromIterable(entityList).filter(new Predicate<AddressEntity>() {
        @Override
        public boolean test(AddressEntity addressInfoEntity) throws Exception {
            return addressInfoEntity != null;
        }
    }).map(new Function<AddressEntity, Address>() {
        @Override
        public Address apply(AddressEntity addressInfoEntity) throws Exception {
            return new Address(addressInfoEntity.getUuid(), addressInfoEntity.getName(), addressInfoEntity.getAddress(), addressInfoEntity.getAvatar());
        }
    }).toList().blockingGet();
    assertNotNull(list);
    for(Address address :list){
        System.out.println(address.getUuid() + "=====================" +address.getName());
    }
}