Skip to content

Instantly share code, notes, and snippets.

View JohnWowUs's full-sized avatar

JohnWowUs

  • United Kingdom
View GitHub Profile
sudo apt-get install nvidia-current-updates nvidia-settings-updates
sudo apt-get purge nvidia-*
dkms status | grep nvidia
sudo dkms remove nvidia-current-updates/304.64 -k 3.2.0-37-generic
import rx.*;
import rx.functions.Func1;
import rx.internal.producers.ProducerArbiter;
import rx.subscriptions.SerialSubscription;
public final class OperatorSwitchIfMatch<T> implements Observable.Operator<T, T> {
private final Observable<? extends T> alternate;
private final Func1<T, Boolean> selector ;
public OperatorSwitchIfMatch(Observable<? extends T> alternate, Func1<T, Boolean> selector) {
@JohnWowUs
JohnWowUs / OperatorTakeUntilComplete.java
Created May 11, 2016 14:34
RxJava TakeUntilComplete Operator
import rx.Observable;
import rx.Observable.Operator;
import rx.Subscriber;
import rx.observers.SerializedSubscriber;
public final class OperatorTakeUntilComplete<T, E> implements Operator<T, T> {
private final Observable<? extends E> other;
public OperatorTakeUntilComplete(final Observable<? extends E> other) {
import rx.Observable;
import rx.Observable.Operator;
import rx.Subscriber;
import rx.observers.SerializedSubscriber;
public final class OperatorTakeUntilComplete<T, E> implements Operator<T, T> {
private final Observable<? extends E> other;
public OperatorTakeUntilComplete(final Observable<? extends E> other) {