io.servicetalk.transport.netty.internal

Class NettyConnection.TerminalPredicate<Read>

java.lang.Object

io.servicetalk.transport.netty.internal.NettyConnection.TerminalPredicate<Read>

Type Parameters:

Read - Type of objects tested by this Predicate.

All Implemented Interfaces:

java.util.function.Predicate<Read>

Enclosing interface:

NettyConnection<Read,Write>

public static final class NettyConnection.TerminalPredicate<Read>
extends java.lang.Object
implements java.util.function.Predicate<Read>

A dynamic Predicate to detect terminal message in a stream as returned by NettyConnection.read(). Use replaceCurrent(Predicate) for replacing the current Predicate and discardIfCurrent(Predicate) to revert back to the original Predicate.

If a dynamic predicate (as set by replaceCurrent(Predicate) terminates the stream, this will automatically revert to the original Predicate as done by calling discardIfCurrent(Predicate).

Constructor Summary

Constructors

Constructor and Description
TerminalPredicate(java.util.function.Predicate<Read> original) New instance.

Method Summary

Modifier and Type	Method and Description
boolean	discardIfCurrent(java.util.function.Predicate<Read> current) Discards the current Predicate (if same as passed current) and sets current as the original Predicate.
void	replaceCurrent(java.util.function.Predicate<Read> next) Sets current Predicate to next.
boolean	test(Read read)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Predicate

and, isEqual, negate, or

Constructor Detail

TerminalPredicate

public TerminalPredicate(java.util.function.Predicate<Read> original)

New instance.

Parameters:

original - Predicate. This is the Predicate that will be set as current after discardIfCurrent(Predicate) is called.

Method Detail

replaceCurrent

public void replaceCurrent(java.util.function.Predicate<Read> next)

Sets current Predicate to next.

Parameters:

next - Predicate to set as current.

discardIfCurrent

public boolean discardIfCurrent(java.util.function.Predicate<Read> current)

Discards the current Predicate (if same as passed current) and sets current as the original Predicate.

Parameters:

current - Predicate to discard if current.

Returns:

true if the predicate was discarded.

test

public boolean test(Read read)

Specified by:

test in interface java.util.function.Predicate<Read>