reactor.core.publisher

类 FluxOnBackpressureBufferStrategyTest

java.lang.Object

reactor.core.publisher.FluxOnBackpressureBufferStrategyTest

所有已实现的接口:

java.util.function.BiFunction<java.lang.Throwable,java.lang.Object,java.lang.Throwable>, java.util.function.Consumer<java.lang.String>

public class FluxOnBackpressureBufferStrategyTest
extends java.lang.Object
implements java.util.function.Consumer<java.lang.String>, java.util.function.BiFunction<java.lang.Throwable,java.lang.Object,java.lang.Throwable>

构造器概要

构造器

构造器和说明
FluxOnBackpressureBufferStrategyTest()

方法概要

限定符和类型	方法和说明
void	accept(java.lang.String s)
void	after()
java.lang.Throwable	apply(java.lang.Throwable throwable, java.lang.Object o)
void	before()
void	bufferOverflowOverflowDelayedWithErrorStrategy()
void	drop()
void	dropCallbackError()
void	dropOldest()
void	dropOldestCallbackError()
void	error()
void	errorCallbackError()
void	fluxOnBackpressureBufferStrategyNoCallback()
void	noCallbackWithDropOldestStrategyNoError()
void	noCallbackWithDropStrategyNoError()
void	noCallbackWithErrorStrategyOverflowsAfterDrain()
void	onBackpressureBufferMaxCallbackOverflowDropLatest()
void	onBackpressureBufferMaxCallbackOverflowDropOldest()
void	onBackpressureBufferMaxCallbackOverflowError()
void	onBackpressureBufferWithBadSourceEmitsAfterComplete()
void	scanOperator()
void	scanSubscriber()

从类继承的方法 java.lang.Object

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

从接口继承的方法 java.util.function.Consumer

andThen

从接口继承的方法 java.util.function.BiFunction

andThen

构造器详细资料

FluxOnBackpressureBufferStrategyTest

public FluxOnBackpressureBufferStrategyTest()

方法详细资料

accept

public void accept(java.lang.String s)

指定者:

accept 在接口中 java.util.function.Consumer<java.lang.String>

apply

public java.lang.Throwable apply(java.lang.Throwable throwable,
                                 java.lang.Object o)

指定者:

apply 在接口中 java.util.function.BiFunction<java.lang.Throwable,java.lang.Object,java.lang.Throwable>

before

@BeforeEach
public void before()

after

@AfterEach
public void after()

bufferOverflowOverflowDelayedWithErrorStrategy

@Test
public void bufferOverflowOverflowDelayedWithErrorStrategy()

drop

@Test
public void drop()

dropOldest

@Test
public void dropOldest()

error

@Test
public void error()

onBackpressureBufferMaxCallbackOverflowError

@Test
public void onBackpressureBufferMaxCallbackOverflowError()

onBackpressureBufferMaxCallbackOverflowDropOldest

@Test
public void onBackpressureBufferMaxCallbackOverflowDropOldest()

onBackpressureBufferMaxCallbackOverflowDropLatest

@Test
public void onBackpressureBufferMaxCallbackOverflowDropLatest()

onBackpressureBufferWithBadSourceEmitsAfterComplete

@Test
public void onBackpressureBufferWithBadSourceEmitsAfterComplete()

dropCallbackError

@Test
public void dropCallbackError()

dropOldestCallbackError

@Test
public void dropOldestCallbackError()

errorCallbackError

@Test
public void errorCallbackError()

noCallbackWithErrorStrategyOverflowsAfterDrain

@Test
public void noCallbackWithErrorStrategyOverflowsAfterDrain()

noCallbackWithDropStrategyNoError

@Test
public void noCallbackWithDropStrategyNoError()

noCallbackWithDropOldestStrategyNoError

@Test
public void noCallbackWithDropOldestStrategyNoError()

fluxOnBackpressureBufferStrategyNoCallback

@Test
public void fluxOnBackpressureBufferStrategyNoCallback()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()