// Path: 2016-07-12_rxjava_in_action/src/main/java/com/androidhuman/example/rxjavainaction/error/ContentNotAvailableError.java
// public final class ContentNotAvailableError extends Error {
// 
// }


import com.androidhuman.example.rxjavainaction.error.ContentNotAvailableError;
import com.androidhuman.example.rxjavainaction.model.Content;
import rx.Observable;
import rx.Subscriber;
package com.androidhuman.example.rxjavainaction.rx;



final class ChecksAvailabilityOnSubscribe implements Observable.OnSubscribe<Void> {

    private final Content content;

    ChecksAvailabilityOnSubscribe(Content content) {
        this.content = content;
    }

// Path: 2016-07-12_rxjava_in_action/src/main/java/com/androidhuman/example/rxjavainaction/error/ContentNotAvailableError.java
// public final class ContentNotAvailableError extends Error {
// 
// }


// Path: 2016-07-12_rxjava_in_action/src/main/java/com/androidhuman/example/rxjavainaction/rx/ChecksAvailabilityOnSubscribe.java
import com.androidhuman.example.rxjavainaction.error.ContentNotAvailableError;
import com.androidhuman.example.rxjavainaction.model.Content;
import rx.Observable;
import rx.Subscriber;

package com.androidhuman.example.rxjavainaction.rx;



final class ChecksAvailabilityOnSubscribe implements Observable.OnSubscribe<Void> {

    private final Content content;

    ChecksAvailabilityOnSubscribe(Content content) {
        this.content = content;
    }

    @Override