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)

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

 //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

//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

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

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

//AutoSearch using debounce spell
  public Observable<SearchRequest> autoSearch() {
      return getSearchtermObservable()
              .debounce(500, TimeUnit.MILLISECONDS)
              .flatMap(new Func1<String, Observable<SearchRequest>>() {
                  @Override
                  public Observable<SearchRequest> call(String term) {
                      return Observable.just(new SearchRequest(term));
                  }
              });

ragdroid

  private class Boggart {
      private static final int MAX_LAUGHTER_LEVEL = 10;
      private static final int MIN_LAUNGHTER_LEVEL = 0;
      private static final int LAUGHTER_FUNNY_THRESHOLD = 5;
      private static final int LAUGHTER_HILARIOUS_THRESH = 7;
      private int laughterLevel;

      public Boggart() {
          init();

ragdroid

// Example of repeat and retry
  private Observable<Boggart> riddikulus() {
      return getBoggartObservable()
              .flatMap(new Func1<Boggart, Observable<Boggart>>() {
                  @Override
                  public Observable<Boggart> call(Boggart boggart) {
                      boggart.init();
                      boggart.riddikulus();
                      if (boggart.isFunny()) {

ragdroid

//Retry when IOException
    Observable<UserResponse> getUserFromServer() {
        return userService.getUserFromServer()
                .retryWhen(new Func1<Observable<? extends Throwable>, Observable<?>>() {
                    @Override
                    public Observable<?> call(Observable<? extends Throwable> observable) {
                        return observable.flatMap(new Func1<Throwable, Observable<?>>() {
                            @Override
                            public Observable<?> call(Throwable throwable) {