Package io.micronaut.http.filter

Class GenericHttpFilter.TerminalReactive

java.lang.Object

io.micronaut.http.filter.GenericHttpFilter.TerminalReactive

All Implemented Interfaces:

GenericHttpFilter, GenericHttpFilter.Terminal

Enclosing interface:

GenericHttpFilter

@Internal
public static final class GenericHttpFilter.TerminalReactive
extends Object
implements GenericHttpFilter.Terminal

Terminal filter that accepts a reactive type. Used as a temporary solution for the http client, until that is un-reactified.

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.http.filter.GenericHttpFilter

GenericHttpFilter.AroundLegacy, GenericHttpFilter.Async, GenericHttpFilter.Terminal, GenericHttpFilter.TerminalReactive

Constructor Summary

Constructors

Constructor	Description
TerminalReactive(Publisher<? extends HttpResponse<?>> responsePublisher)

Method Summary

Modifier and Type	Method	Description
ExecutionFlow<? extends HttpResponse<?>>	execute(HttpRequest<?> request)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.http.filter.GenericHttpFilter

isFiltersException, isSuspended

Constructor Details

TerminalReactive

public TerminalReactive(Publisher<? extends HttpResponse<?>> responsePublisher)

Parameters:

responsePublisher - The response publisher

Method Details

execute

public ExecutionFlow<? extends HttpResponse<?>> execute(HttpRequest<?> request)
                                                 throws Exception

Specified by:

execute in interface GenericHttpFilter.Terminal

Throws:

Exception