Package me.ahoo.cosid.mongo.reactive

Class BlockingAdapter

java.lang.Object

me.ahoo.cosid.mongo.reactive.BlockingAdapter

public final class BlockingAdapter
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_TIME_OUT

Method Summary

Modifier and Type	Method	Description
static <R> R	block(org.reactivestreams.Publisher<R> publisher)
static <R> R	block(reactor.core.publisher.Mono<R> mono)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_TIME_OUT

public static final Duration DEFAULT_TIME_OUT

Method Details

block

public static <R> R block(org.reactivestreams.Publisher<R> publisher)

block

public static <R> R block(reactor.core.publisher.Mono<R> mono)