public class org.springframework.messaging.simp.stomp.Reactor2StompCodec extends reactor.io.codec.Codec
{
private final reactor.fn.Function encodingFunction;
private final org.springframework.messaging.simp.stomp.StompDecoder stompDecoder;
public void <init>()
{
org.springframework.messaging.simp.stomp.StompDecoder v;
org.springframework.messaging.simp.stomp.StompEncoder v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2StompCodec;
v = new org.springframework.messaging.simp.stomp.StompEncoder;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompEncoder: void <init>()>();
v = new org.springframework.messaging.simp.stomp.StompDecoder;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompDecoder: void <init>()>();
specialinvoke v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: void <init>(org.springframework.messaging.simp.stomp.StompEncoder,org.springframework.messaging.simp.stomp.StompDecoder)>(v, v);
return;
}
public void <init>(org.springframework.messaging.simp.stomp.StompEncoder, org.springframework.messaging.simp.stomp.StompDecoder)
{
org.springframework.messaging.simp.stomp.StompDecoder v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec$EncodingFunction v;
org.springframework.messaging.simp.stomp.StompEncoder v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2StompCodec;
v := @parameter: org.springframework.messaging.simp.stomp.StompEncoder;
v := @parameter: org.springframework.messaging.simp.stomp.StompDecoder;
specialinvoke v.<reactor.io.codec.Codec: void <init>()>();
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "StompEncoder is required");
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "StompDecoder is required");
v = new org.springframework.messaging.simp.stomp.Reactor2StompCodec$EncodingFunction;
specialinvoke v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec$EncodingFunction: void <init>(org.springframework.messaging.simp.stomp.StompEncoder)>(v);
v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: reactor.fn.Function encodingFunction> = v;
v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: org.springframework.messaging.simp.stomp.StompDecoder stompDecoder> = v;
return;
}
public reactor.fn.Function decoder(reactor.fn.Consumer)
{
org.springframework.messaging.simp.stomp.StompDecoder v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec$DecodingFunction v;
reactor.fn.Consumer v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2StompCodec;
v := @parameter: reactor.fn.Consumer;
v = new org.springframework.messaging.simp.stomp.Reactor2StompCodec$DecodingFunction;
v = v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: org.springframework.messaging.simp.stomp.StompDecoder stompDecoder>;
specialinvoke v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec$DecodingFunction: void <init>(org.springframework.messaging.simp.stomp.StompDecoder,reactor.fn.Consumer)>(v, v);
return v;
}
public reactor.fn.Function encoder()
{
reactor.fn.Function v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2StompCodec;
v = v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: reactor.fn.Function encodingFunction>;
return v;
}
public reactor.io.buffer.Buffer apply(org.springframework.messaging.Message)
{
reactor.fn.Function v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
java.lang.Object v;
org.springframework.messaging.Message v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2StompCodec;
v := @parameter: org.springframework.messaging.Message;
v = v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: reactor.fn.Function encodingFunction>;
v = interfaceinvoke v.<reactor.fn.Function: java.lang.Object apply(java.lang.Object)>(v);
return v;
}
}