ragdroid

//buffer analytics events to optimize network traffic
  public Observable<TrackRequest> bufferundum() {
      return getUserEventsObservable()
              .buffer(3) //buffer count
              .flatMap(new Func1<List<Event>, Observable<TrackRequest>>() {
                  @Override
                  public Observable<TrackRequest> call(final List<Event> events) {
                      return Observable.just(new TrackRequest(events));
                  }

ragdroid

 
 //Concatify spell
  Observable<List<Lecture>> getLectures() {
      Observable<List<Lecture>> cacheObservable = getLecturesFromCache();
      Observable<List<Lecture>> lecturesFromServer = getLecturesFromServer();
      return cacheObservable.concatWith(lecturesFromServer)
              .take(1);
  }
  

ragdroid

//concatify
 Observable<Student> concatify() {
    Observable<Student> slytherinObservable = getObservable(House.SLYTHERIN);
    Observable<Student> huffleObervable = getObservable(House.HUFFLEPUFF);
    Observable<Student> ravenObservable = getObservable(House.RAVENCLAW);
    Observable<Student> gryffindorObservable = getObservable(House.GRYFFINDOR);
    return Observable.concat(
            slytherinObservable,
            huffleObervable,

ragdroid

 //It's zip-yOsa not zip-yosAR 
  Observable<DanceCouple> getYuleDanceCoupleObservable() {
      Observable<Champion> championsObservable = getChampionsObservable();
      Observable<Partner> partnerObservable = getPartnerObservable();
      return championsObservable.zipWith(partnerObservable, new Func2<Champion, Partner, DanceCouple>() {
          @Override
          public DanceCouple call(Champion champion, Partner partner) {
              return new DanceCouple(champion, partner).dance();
          }
      });

ragdroid

//Preparing a polyjuice? Simple cast the spell - Zippyosa !!

	Observable<PolyJuice> getPolyJuiceObservable() {
		Observable<FluxWeed> ronObservable = getFluxWeedObservable();
		Observable<CrabHair> harryObservable = getHairObservable();
		return Observable.zip(ronObservable, harryObservable, new Func2<FluxWeed, CrabHair, PolyJuice>() {
			@Override
			public PolyJuice call(final FluxWeed fluxWeed, final CrabHair crabHair) {
				return new PolyJuice(fluxWeed, crabHair)
						.prepare();

ragdroid

//Preparing a polyjuice? Simple cast the spell - Zippyosa !!
public class Zippyosa {

	Observable<PolyJuice> getPolyJuiceObservable() {
		Observable<FluxWeed> ronObservable = getFluxWeedObservable();
		Observable<CrabHair> harryObservable = getHairObservable();
		return Observable.zip(ronObservable, harryObservable, new Func2<FluxWeed, CrabHair, PolyJuice>() {
			@Override
			public PolyJuice call(final FluxWeed fluxWeed, final CrabHair crabHair) {
				return new PolyJuice(fluxWeed, crabHair)