reactor.core.publisher

类 MonoSubscriberTest

java.lang.Object

reactor.core.publisher.MonoSubscriberTest

public class MonoSubscriberTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
MonoSubscriberTest()

方法概要

限定符和类型	方法和说明
void	clear()
void	completeCancelRace()
void	issue1719()
void	queueSubscriptionAsyncRejected()
void	queueSubscriptionSyncRejected()
static void	race(java.lang.Runnable r1, java.lang.Runnable r2, Scheduler s) Synchronizes the execution of two runnables (as much as possible) to test race conditions.
void	requestCancelRace()
void	requestClearRace()

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

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

构造器详细资料

MonoSubscriberTest

public MonoSubscriberTest()

方法详细资料

queueSubscriptionSyncRejected

@Test
public void queueSubscriptionSyncRejected()

queueSubscriptionAsyncRejected

@Test
public void queueSubscriptionAsyncRejected()

clear

@Test
public void clear()

completeCancelRace

@Test
public void completeCancelRace()

requestClearRace

@Test
public void requestClearRace()

requestCancelRace

@Test
public void requestCancelRace()

race

public static void race(java.lang.Runnable r1,
                        java.lang.Runnable r2,
                        Scheduler s)

Synchronizes the execution of two runnables (as much as possible) to test race conditions.

The method blocks until both have run to completion.

参数:

r1 - the first runnable

r2 - the second runnable

s - the scheduler to use

issue1719

@Test
public void issue1719()