Classe « SubmissionPublisher<T> »

Informations générales

java.lang.Object
    java.util.concurrent.SubmissionPublisher

java.lang.AutoCloseable
java.util.concurrent.Flow$Publisher<T>

public class SubmissionPublisher<T> extends java.lang.Object
implements java.lang.AutoCloseable,
           java.util.concurrent.Flow$Publisher<T>

A venir.

Tous les attributs Attributs d'instance Attributs statiques Attributs dépréciés

Qualificateurs	Type	Nom	Description

Constructeurs Constructeurs dépréciés

Constructeur	Description
SubmissionPublisher()
SubmissionPublisher( Executor executor, int maxBufferCapacity )
SubmissionPublisher( Executor executor, int maxBufferCapacity, BiConsumer<? super java.util.concurrent.Flow$Subscriber<? super T>, ? super java.lang.Throwable> handler )

Propriétés Propriétés dépréciées

Qualificateurs	Type	Nom	R/W
public	boolean	closed	R/-
public	Throwable	closedException	R/-
public	Executor	executor	R/-
public	int	maxBufferCapacity	R/-
public	int	numberOfSubscribers	R/-
public	List	subscribers	R/-

class

Toutes les méthodes Méthodes d'instance Méthodes statiques Méthodes concrètes Méthodes abstraites Méthodes dépréciées

Qualificateurs	Type de retour	Prototype de la méthode
public	void	close()
public	void	closeExceptionally( Throwable error )
public	CompletableFuture<java.lang.Void>	consume( Consumer<? super T> consumer )
public	int	estimateMaximumLag()
public	long	estimateMinimumDemand()
public	Throwable	getClosedException()
public	Executor	getExecutor()
public	int	getMaxBufferCapacity()
public	int	getNumberOfSubscribers()
public	List<java.util.concurrent.Flow$Subscriber<? super T>>	getSubscribers()
public	boolean	hasSubscribers()
public	boolean	isClosed()
public	boolean	isSubscribed( Subscriber<? super T> subscriber )
public	int	offer( T item, BiPredicate<java.util.concurrent.Flow$Subscriber<? super T>, ? super T> onDrop )
public	int	offer( T item, long timeout, TimeUnit unit, BiPredicate<java.util.concurrent.Flow$Subscriber<? super T>, ? super T> onDrop )
public	int	submit( T item )
public	void	subscribe( Subscriber<? super T> subscriber )