org.hswebframework.web.logger

Class ReactiveLogger

java.lang.Object

org.hswebframework.web.logger.ReactiveLogger

public class ReactiveLogger
extends Object

Constructor Summary

Constructors

Constructor and Description
ReactiveLogger()

Method Summary

Modifier and Type	Method and Description
static <T,R> BiConsumer<T,reactor.core.publisher.SynchronousSink<R>>	handle(BiConsumer<T,reactor.core.publisher.SynchronousSink<R>> logger)
static <T> void	log(reactor.util.context.Context context, Consumer<Map<String,String>> logger)
static reactor.core.publisher.Mono<Void>	mdc(Consumer<Map<String,String>> consumer)
static reactor.core.publisher.Mono<Void>	mdc(String... keyAndValue)
static reactor.core.publisher.Mono<Void>	mdc(String key, String value)
static <T> Consumer<reactor.core.publisher.Signal<T>>	on(reactor.core.publisher.SignalType type, BiConsumer<Map<String,String>,reactor.core.publisher.Signal<T>> logger)
static <T> Consumer<reactor.core.publisher.Signal<T>>	onComplete(Runnable logger)
static <T> Consumer<reactor.core.publisher.Signal<T>>	onError(Consumer<Throwable> logger)
static <T> Consumer<reactor.core.publisher.Signal<T>>	onNext(Consumer<T> logger)
static Function<reactor.util.context.Context,reactor.util.context.Context>	start(Map<String,String> context)
static Function<reactor.util.context.Context,reactor.util.context.Context>	start(String... keyAndValue)
static Function<reactor.util.context.Context,reactor.util.context.Context>	start(String key, String value)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveLogger

public ReactiveLogger()

Method Detail

start

public static Function<reactor.util.context.Context,reactor.util.context.Context> start(String key,
                                                                                        String value)

start

public static Function<reactor.util.context.Context,reactor.util.context.Context> start(String... keyAndValue)

mdc

public static reactor.core.publisher.Mono<Void> mdc(String key,
                                                    String value)

mdc

public static reactor.core.publisher.Mono<Void> mdc(String... keyAndValue)

start

public static Function<reactor.util.context.Context,reactor.util.context.Context> start(Map<String,String> context)

log

public static <T> void log(reactor.util.context.Context context,
                           Consumer<Map<String,String>> logger)

on

public static <T> Consumer<reactor.core.publisher.Signal<T>> on(reactor.core.publisher.SignalType type,
                                                                BiConsumer<Map<String,String>,reactor.core.publisher.Signal<T>> logger)

mdc

public static reactor.core.publisher.Mono<Void> mdc(Consumer<Map<String,String>> consumer)

handle

public static <T,R> BiConsumer<T,reactor.core.publisher.SynchronousSink<R>> handle(BiConsumer<T,reactor.core.publisher.SynchronousSink<R>> logger)

onNext

public static <T> Consumer<reactor.core.publisher.Signal<T>> onNext(Consumer<T> logger)

onComplete

public static <T> Consumer<reactor.core.publisher.Signal<T>> onComplete(Runnable logger)

onError

public static <T> Consumer<reactor.core.publisher.Signal<T>> onError(Consumer<Throwable> logger)