com.google.android.jacquard.sdk.rx

package com.google.android.jacquard.sdk.rx

Classes

Name Description
public class Signal<T> extends Object

A naive reimplementation of rxjava's Observable<T>

Produces an observable stream of T. All operations are single-threaded, but should otherwise be thread-safe.

public static interface interface Signal.SubscriptionFactory<T>
public static interface interface Signal.Observer<T>
public static interface interface Signal.OnSubscribe
public static class Signal.Subscription extends Object
public abstract static class Signal.ObservesNext<T> extends Object implements Observer
public abstract static class Signal.ObservesComplete<T> extends Object implements Observer

Class to observe only complete block in subscription.
public abstract static class Signal.ObservesError extends Object implements Observer

Class to observe only errors in subscription.
public static class Signal.ForwarderObserver<T> extends Object implements Observer
public interface interface Pred<T>
public final class Executors extends Object

Provides executors for signal operators.
public interface interface Fn<T, U>
public interface interface Producer<T>

A producer function, generating a T.
public interface interface Consumer<T>

A representation of T -> ()
public interface interface Fn2<A, B, T>