Observable.range(0, 50)
          .buffer(10)
          .subscribe(integers -> {
              Log.d("tag", "list size recevied after buffering: "+integers.size());
          });