io.reactivex.rxjava3.core

public Interface ObservableOperator<Downstream, Upstream>

Annotations

Type Parameters

Imports

io.reactivex.rxjava3.annotations.NonNull

Interface to map/wrap a downstream Observer to an upstream Observer.

Method Summary

Modifier and Type	Method and Description
public @NonNull Observer<? super Upstream>	Returns: the parent `Observer` instance apply(@NonNull Observer<? super Downstream> the child `Observer` instance observer) Applies a function to the child `Observer` and returns a new parent `Observer`.

apply back to summary

apply	back to summary
public @NonNull Observer<? super Upstream> apply(@NonNull Observer<? super Downstream> observer) throws Throwable Applies a function to the child `Observer` and returns a new parent `Observer`. Parameters observer:@NonNull Observer<? super Downstream> the child `Observer` instance Returns:@NonNull Observer<? super Upstream> the parent `Observer` instance Annotations @NonNull Exceptions Throwable: on failure

public @NonNull Observer<? super Upstream> apply(@NonNull Observer<? super Downstream> observer) throws Throwable

Applies a function to the child Observer and returns a new parent Observer.

Parameters

observer:@NonNull Observer<? super Downstream>: the child Observer instance

Returns:@NonNull Observer<? super Upstream>

the parent Observer instance

Annotations

Exceptions