reactor.core.publisher

类 BlockingTests

java.lang.Object

reactor.core.publisher.BlockingTests

public class BlockingTests
extends java.lang.Object

构造器概要

构造器

构造器和说明
BlockingTests()

方法概要

限定符和类型	方法和说明
static void	after()
static void	before()
void	blockingFirst()
void	blockingFirst2()
void	blockingFirstEarlyComplete()
void	blockingFirstError()
void	blockingFirstError2()
void	blockingFirstTimeout()
void	blockingLast()
void	blockingLast2()
void	blockingLastEarlyComplete()
void	blockingLastError()
void	blockingLastError2()
void	blockingLastInterrupted()
void	blockingLastTimeout()
void	fluxBlockFirstCancelsOnce()
void	fluxBlockFirstForbidden()
void	fluxBlockLastDoesntCancel()
void	fluxBlockLastForbidden()
void	fluxToIterableOkButIterationForbidden()
void	fluxToStreamOkButIterationForbidden()
void	monoBlockDoesntCancel()
void	monoBlockForbidden()
void	monoBlockOptionalDoesntCancel()
void	monoBlockOptionalForbidden()
void	monoBlockSupportsNanos()

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

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

构造器详细资料

BlockingTests

public BlockingTests()

方法详细资料

before

@BeforeAll
public static void before()

after

@AfterAll
public static void after()

blockingFirst

@Test
public void blockingFirst()

blockingFirst2

@Test
public void blockingFirst2()

blockingFirstEarlyComplete

@Test
public void blockingFirstEarlyComplete()

blockingFirstTimeout

@Test
public void blockingFirstTimeout()

blockingLast

@Test
public void blockingLast()

blockingLast2

@Test
public void blockingLast2()

blockingLastEarlyComplete

@Test
public void blockingLastEarlyComplete()

blockingLastTimeout

@Test
public void blockingLastTimeout()

blockingFirstError

@Test
public void blockingFirstError()

blockingFirstError2

@Test
public void blockingFirstError2()

blockingLastError

@Test
public void blockingLastError()

blockingLastError2

@Test
public void blockingLastError2()

blockingLastInterrupted

@Test
public void blockingLastInterrupted()
                                    throws java.lang.Exception

抛出:

java.lang.Exception

fluxBlockFirstCancelsOnce

@Test
public void fluxBlockFirstCancelsOnce()

fluxBlockLastDoesntCancel

@Test
public void fluxBlockLastDoesntCancel()

monoBlockDoesntCancel

@Test
public void monoBlockDoesntCancel()

monoBlockOptionalDoesntCancel

@Test
public void monoBlockOptionalDoesntCancel()

monoBlockSupportsNanos

@Test
public void monoBlockSupportsNanos()

fluxBlockFirstForbidden

@Test
public void fluxBlockFirstForbidden()

fluxBlockLastForbidden

@Test
public void fluxBlockLastForbidden()

monoBlockForbidden

@Test
public void monoBlockForbidden()

monoBlockOptionalForbidden

@Test
public void monoBlockOptionalForbidden()

fluxToIterableOkButIterationForbidden

@Test
public void fluxToIterableOkButIterationForbidden()
                                                  throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

fluxToStreamOkButIterationForbidden

@Test
public void fluxToStreamOkButIterationForbidden()
                                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException