https://github.com/ReactiveX/RxJava: Reactive Extensions for Java
  • David Karnok 
Copyright (c) 2016-present, RxJava Contributors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in
compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is
distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See
the License for the specific language governing permissions and limitations under the License.

/**
 * Copyright (c) 2016-present, RxJava Contributors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in
 * compliance with the License. You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License is
 * distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See
 * the License for the specific language governing permissions and limitations under the License.
 */

package io.reactivex.internal.fuseable;

import io.reactivex.FlowableSubscriber;


A Subscriber with an additional tryOnNext(Object) method that tells the caller the specified value has been accepted or not. 
This allows certain queue-drain or source-drain operators
to avoid requesting 1 on behalf of a dropped value.

Type parameters:
  • <T> – the value type
/**
 * A Subscriber with an additional {@link #tryOnNext(Object)} method that
 * tells the caller the specified value has been accepted or
 * not.
 *
 * <p>This allows certain queue-drain or source-drain operators
 * to avoid requesting 1 on behalf of a dropped value.
 *
 * @param <T> the value type
 */
public interface ConditionalSubscriber<T> extends FlowableSubscriber<T> {
    
Conditionally takes the value.

Params:
  • t – the value to deliver
Returns:true if the value has been accepted, false if the value has been rejected
and the next value can be sent immediately
/**
     * Conditionally takes the value.
     * @param t the value to deliver
     * @return true if the value has been accepted, false if the value has been rejected
     * and the next value can be sent immediately
     */
    boolean tryOnNext(T t);
}