sgr-ksmt

struct ComposeTransformer<T, R> {
    let transformer: (Observable<T>) -> Observable<R>
    init(transformer: @escaping (Observable<T>) -> Observable<R>) {
        self.transformer = transformer
    }
    
    func call(_ observable: Observable<T>) -> Observable<R> {
        return transformer(observable)
    }
}

kaushikgopal

• In general you want to try and put things in onStart and onStop for logical start and stops.

Activity

onCreate

• Dagger inject self into graph
• setContentView(R.layout.xxx)
• Butterknife.bind(this)
• RxJava CompositeSubscription.add (if NON UI related work being done)
• realm = Realm.getDefaultInstance();

alexfu

/*
 * Copyright (C) 2014 The Android Open Source Project
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

staltz

The introduction to Reactive Programming you've been missing

(by @andrestaltz)

---

This tutorial as a series of videos

If you prefer to watch video tutorials with live-coding, then check out this series I recorded with the same contents as in this article: Egghead.io - Introduction to Reactive Programming.

---

xrigau

<?xml version="1.0" encoding="utf-8"?>
<manifest
  xmlns:android="http://schemas.android.com/apk/res/android"
  package="com.novoda.espresso">
  
  <!-- For espresso testing purposes, this is removed in live builds, but not in dev builds -->
  <uses-permission android:name="android.permission.SET_ANIMATION_SCALE" />

  <!-- ... -->
  

swanson

import android.annotation.SuppressLint;
import android.content.Context;
import android.util.Log;

import retrofit.client.Client;
import retrofit.client.Header;
import retrofit.client.Request;
import retrofit.client.Response;
import retrofit.mime.TypedInput;

JakeWharton

import com.android.volley.toolbox.HurlStack;
import com.squareup.okhttp.OkHttpClient;
import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.URL;

/**
 * An {@link com.android.volley.toolbox.HttpStack HttpStack} implementation which
 * uses OkHttp as its transport.
 */

mahata

var appid = 'XXX', // MODIFY ME
    query = encodeURI('search me'),
    num   = 2;

var request_url = {
    host: 'search.yahooapis.jp',
    path: '/PremiumWebSearchService/V1/webSearch?' +
        'appid=' + appid + '&' +
        'query=' + query + '&' +
        'results=' + num,