io.micronaut.http.server.netty.binders

Class PublisherBodyBinder

java.lang.Object

io.micronaut.http.bind.binders.DefaultBodyAnnotationBinder<org.reactivestreams.Publisher>

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

All Implemented Interfaces:

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

@Singleton
public class PublisherBodyBinder
extends DefaultBodyAnnotationBinder<org.reactivestreams.Publisher>
implements NonBlockingBodyArgumentBinder<org.reactivestreams.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 inherited from class io.micronaut.http.bind.binders.DefaultBodyAnnotationBinder

conversionService

Constructor Summary

Constructors

Constructor and Description
PublisherBodyBinder(ConversionService conversionService, HttpContentProcessorResolver httpContentProcessorResolver)

Method Summary

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

Methods inherited from class io.micronaut.http.bind.binders.DefaultBodyAnnotationBinder

getAnnotationType

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.AnnotatedRequestArgumentBinder

of

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

superTypes

Constructor Detail

PublisherBodyBinder

public PublisherBodyBinder(ConversionService conversionService,
                           HttpContentProcessorResolver httpContentProcessorResolver)

Parameters:

conversionService - The conversion service

httpContentProcessorResolver - The http content processor resolver

Method Detail

argumentType

public Argument<org.reactivestreams.Publisher> argumentType()

Specified by:

argumentType in interface TypeArgumentBinder<org.reactivestreams.Publisher,HttpRequest<?>>

Returns:

The argument type.

bind

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

Description copied from interface: ArgumentBinder

Bind the given argument from the given source.

Specified by:

bind in interface ArgumentBinder<org.reactivestreams.Publisher,HttpRequest<?>>

Overrides:

bind in class DefaultBodyAnnotationBinder<org.reactivestreams.Publisher>

Parameters:

context - The ArgumentConversionContext

source - The source

Returns:

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