本文整理了Java中io.reactivex.annotations.NonNull.<init>()
方法的一些代码示例,展示了NonNull.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NonNull.<init>()
方法的具体详情如下:
包路径:io.reactivex.annotations.NonNull
类名称:NonNull
方法名:<init>
暂无
代码示例来源:origin: ReactiveX/RxJava
/**
* Ensures that calls to onNext, onError and onComplete are properly serialized.
* @return the serialized ObservableEmitter
*/
@NonNull
ObservableEmitter<T> serialize();
代码示例来源:origin: ReactiveX/RxJava
/**
* Test the given input values and return a boolean.
* @param t1 the first value
* @param t2 the second value
* @return the boolean result
* @throws Exception on error
*/
boolean test(@NonNull T1 t1, @NonNull T2 t2) throws Exception;
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Implement this method in subclasses to handle the incoming {@link SingleObserver}s.
* <p>There is no need to call any of the plugin hooks on the current {@code Single} instance or
* the {@code SingleObserver}; all hooks and basic safeguards have been
* applied by {@link #subscribe(SingleObserver)} before this method gets called.
* @param observer the SingleObserver to handle, not null
*/
protected abstract void subscribeActual(@NonNull SingleObserver<? super T> observer);
代码示例来源:origin: ReactiveX/RxJava
public ObservableWithLatestFromMany(@NonNull ObservableSource<T> source, @NonNull Iterable<? extends ObservableSource<?>> otherIterable, @NonNull Function<? super Object[], R> combiner) {
super(source);
this.otherArray = null;
this.otherIterable = otherIterable;
this.combiner = combiner;
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Applies a function to the upstream Observable and returns an ObservableSource with
* optionally different element type.
* @param upstream the upstream Observable instance
* @return the transformed ObservableSource instance
*/
@NonNull
ObservableSource<Downstream> apply(@NonNull Observable<Upstream> upstream);
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Applies a function to the upstream Maybe and returns a converted value of type {@code R}.
*
* @param upstream the upstream Maybe instance
* @return the converted value
*/
@NonNull
R apply(@NonNull Maybe<T> upstream);
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Notifies the SingleObserver that the {@link Single} has experienced an error condition.
* <p>
* If the {@link Single} calls this method, it will not thereafter call {@link #onSuccess}.
*
* @param e
* the exception encountered by the Single
*/
void onError(@NonNull Throwable e);
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Implementors of this method should make sure everything that needs
* to be visible in {@link #onNext(Object)} is established before
* calling {@link Subscription#request(long)}. In practice this means
* no initialization should happen after the {@code request()} call and
* additional behavior is thread safe in respect to {@code onNext}.
*
* {@inheritDoc}
*/
@Override
void onSubscribe(@NonNull Subscription s);
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Called once if the deferred computation 'throws' an exception.
* @param e the exception, not null.
*/
void onError(@NonNull Throwable e);
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Retrieves the list of exceptions that make up the {@code CompositeException}.
*
* @return the exceptions that make up the {@code CompositeException}, as a {@link List} of {@link Throwable}s
*/
@NonNull
public List<Throwable> getExceptions() {
return exceptions;
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Called for each CompletableObserver that subscribes.
* @param emitter the safe emitter instance, never null
* @throws Exception on error
*/
void subscribe(@NonNull CompletableEmitter emitter) throws Exception;
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Disposable scheduleDirect(@NonNull Runnable run, long delay, TimeUnit unit) {
throw new UnsupportedOperationException("This scheduler doesn't support delayed execution");
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Disposable schedulePeriodicallyDirect(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) {
throw new UnsupportedOperationException("This scheduler doesn't support periodic execution");
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Disposable schedule(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit) {
if (disposed) {
return EmptyDisposable.INSTANCE;
}
return poolWorker.scheduleActual(action, delayTime, unit, timed);
}
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Construct a Disposable by wrapping a Future that is
* cancelled exactly once when the Disposable is disposed.
* @param future the Future to wrap
* @param allowInterrupt if true, the future cancel happens via Future.cancel(true)
* @return the new Disposable instance
*/
@NonNull
public static Disposable fromFuture(@NonNull Future<?> future, boolean allowInterrupt) {
ObjectHelper.requireNonNull(future, "future is null");
return new FutureDisposable(future, allowInterrupt);
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Constructs an onNext notification containing the given value.
* @param <T> the value type
* @param value the value to carry around in the notification, not null
* @return the new Notification instance
* @throws NullPointerException if value is null
*/
@NonNull
public static <T> Notification<T> createOnNext(@NonNull T value) {
ObjectHelper.requireNonNull(value, "value is null");
return new Notification<T>(value);
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Worker createWorker() {
return new ExecutorWorker(executor, interruptibleWorker);
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Disposable schedule(@NonNull Runnable action) {
action.run();
return mockDisposable; // this subscription is returned but discarded
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Disposable schedule(@NonNull final Runnable action) {
return actualInner.schedule(action, delay, unit);
}
代码示例来源:origin: ReactiveX/RxJava
@NonNull
@Override
public Disposable schedule(@NonNull final Runnable action) {
return actualInner.schedule(action, delay, unit);
}
内容来源于网络,如有侵权,请联系作者删除!