Top Description Methods
reactor.core.publisher

pack-priv Interface DirectInnerContainer<T>

Known Direct Implementers
reactor.core.publisher.SinkManyBestEffort, reactor.core.publisher.DirectProcessor
Annotations
@Deprecated

Deprecated

remove again once DirectProcessor is removed

A package-private interface allowing to mutualize logic between DirectProcessor and SinkManyBestEffort.
Author
Simon Baslé

Method Summary

Modifier and TypeMethod and Description
public boolean

Returns:

true if the inner could be added, false if the publisher cannot accept new subscribers
add(SinkManyBestEffort.DirectInner<T>
the new SinkManyBestEffort.DirectInner to add
s)

Add a new SinkManyBestEffort.DirectInner to this publisher.

public void
remove(SinkManyBestEffort.DirectInner<T>
the SinkManyBestEffort.DirectInner to remove
s)

Remove an SinkManyBestEffort.DirectInner from this publisher.

Method Detail

addback to summary
public boolean add(SinkManyBestEffort.DirectInner<T> s)

Add a new SinkManyBestEffort.DirectInner to this publisher.

Parameters
s:SinkManyBestEffort.DirectInner<T>

the new SinkManyBestEffort.DirectInner to add

Returns:boolean

true if the inner could be added, false if the publisher cannot accept new subscribers

removeback to summary
public void remove(SinkManyBestEffort.DirectInner<T> s)

Remove an SinkManyBestEffort.DirectInner from this publisher. Does nothing if the inner is not currently managed by the publisher.

Parameters
s:SinkManyBestEffort.DirectInner<T>

the SinkManyBestEffort.DirectInner to remove