Package io.micronaut.http.server.netty.binders

Class PublisherBodyBinder

java.lang.Object

io.micronaut.http.server.netty.binders.PublisherBodyBinder

All Implemented Interfaces:

AnnotatedArgumentBinder<Body,Publisher<?>,HttpRequest<?>>, ArgumentBinder<Publisher<?>,HttpRequest<?>>, TypeArgumentBinder<Publisher<?>,HttpRequest<?>>, AnnotatedRequestArgumentBinder<Body,Publisher<?>>, BodyArgumentBinder<Publisher<?>>, NonBlockingBodyArgumentBinder<Publisher<?>>, RequestArgumentBinder<Publisher<?>>, TypedRequestArgumentBinder<Publisher<?>>

@Singleton
public class PublisherBodyBinder
extends Object
implements NonBlockingBodyArgumentBinder<Publisher<?>>

A Body argument binder for a reactive streams Publisher.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.core.bind.ArgumentBinder

ArgumentBinder.BindingResult<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	MSG_CONVERT_DEBUG

Constructor Summary

Constructors

Constructor	Description
PublisherBodyBinder(ConversionService conversionService, HttpContentProcessorResolver httpContentProcessorResolver)

Method Summary

Modifier and Type	Method	Description
Argument<Publisher<?>>	argumentType()
ArgumentBinder.BindingResult<Publisher<?>>	bind(ArgumentConversionContext<Publisher<?>> context, HttpRequest<?> source)	Bind the given argument from the given source.

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.bind.binders.BodyArgumentBinder

getAnnotationType

Methods inherited from interface io.micronaut.http.bind.binders.TypedRequestArgumentBinder

matches, superTypes

Field Details

MSG_CONVERT_DEBUG

public static final String MSG_CONVERT_DEBUG

See Also:

• Constant Field Values

Constructor Details

PublisherBodyBinder

public PublisherBodyBinder(ConversionService conversionService,
 HttpContentProcessorResolver httpContentProcessorResolver)

Parameters:

conversionService - The conversion service

httpContentProcessorResolver - The http content processor resolver

Method Details

argumentType

public Argument<Publisher<?>> argumentType()

Specified by:

argumentType in interface TypeArgumentBinder<Publisher<?>,HttpRequest<?>>

Returns:

The argument type.

bind

public ArgumentBinder.BindingResult<Publisher<?>> bind(ArgumentConversionContext<Publisher<?>> context,
 HttpRequest<?> source)

Description copied from interface: ArgumentBinder

Bind the given argument from the given source.

Specified by:

bind in interface ArgumentBinder<Publisher<?>,HttpRequest<?>>

Parameters:

context - The ArgumentConversionContext

source - The source

Returns:

An Optional of the value. If no binding was possible Optional.empty()