com.alibaba.spring.boot.rsocket.hessian

Class HessianDecoder

java.lang.Object

com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

com.alibaba.spring.boot.rsocket.hessian.HessianDecoder

All Implemented Interfaces:

org.springframework.core.codec.Decoder<Object>

public class HessianDecoder
extends HessianCodecSupport
implements org.springframework.core.codec.Decoder<Object>

Hessian Decoder

Author:

leijuan

Field Summary

Fields inherited from class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

HESSIAN_MIME_TYPE, HESSIAN_MIME_TYPES

Constructor Summary

Constructors

Constructor and Description
HessianDecoder()

Method Summary

Modifier and Type	Method and Description
boolean	canDecode(@NotNull org.springframework.core.ResolvableType elementType, org.springframework.util.MimeType mimeType)
@NotNull reactor.core.publisher.Flux<Object>	decode(@NotNull org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream, @NotNull org.springframework.core.ResolvableType elementType, org.springframework.util.MimeType mimeType, Map<String,Object> hints)
@NotNull reactor.core.publisher.Mono<Object>	decodeToMono(@NotNull org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream, @NotNull org.springframework.core.ResolvableType elementType, org.springframework.util.MimeType mimeType, Map<String,Object> hints)
@NotNull List<org.springframework.util.MimeType>	getDecodableMimeTypes()

Methods inherited from class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

decode, encode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.core.codec.Decoder

decode

Constructor Detail

HessianDecoder

public HessianDecoder()

Method Detail

canDecode

public boolean canDecode(@NotNull
                         @NotNull org.springframework.core.ResolvableType elementType,
                         org.springframework.util.MimeType mimeType)

Specified by:

canDecode in interface org.springframework.core.codec.Decoder<Object>

decode

@NotNull
public @NotNull reactor.core.publisher.Flux<Object> decode(@NotNull
                                                                    @NotNull org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream,
                                                                    @NotNull
                                                                    @NotNull org.springframework.core.ResolvableType elementType,
                                                                    org.springframework.util.MimeType mimeType,
                                                                    Map<String,Object> hints)

Specified by:

decode in interface org.springframework.core.codec.Decoder<Object>

decodeToMono

@NotNull
public @NotNull reactor.core.publisher.Mono<Object> decodeToMono(@NotNull
                                                                          @NotNull org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream,
                                                                          @NotNull
                                                                          @NotNull org.springframework.core.ResolvableType elementType,
                                                                          org.springframework.util.MimeType mimeType,
                                                                          Map<String,Object> hints)

Specified by:

decodeToMono in interface org.springframework.core.codec.Decoder<Object>

getDecodableMimeTypes

@NotNull
public @NotNull List<org.springframework.util.MimeType> getDecodableMimeTypes()

Specified by:

getDecodableMimeTypes in interface org.springframework.core.codec.Decoder<Object>