org.springframework.http.server.reactive

Class ChannelSendOperator<T>

java.lang.Object

<any>

org.springframework.http.server.reactive.ChannelSendOperator<T>

public class ChannelSendOperator<T>
extends <any>

Given a write function that accepts a source Publisher<T> to write with and returns Publisher<Void> for the result, this operator helps to defer the invocation of the write function, until we know if the source publisher will begin publishing without an error. If the first emission is an error, the write function is bypassed, and the error is sent directly through the result publisher. Otherwise the write function is invoked.

Since:

5.0

Author:

Rossen Stoyanchev, Stephane Maldini

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ChannelSendOperator.DownstreamBridge
private class	ChannelSendOperator.WriteWithBarrier

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.function.Function<<any>,<any>>	writeFunction

Constructor Summary

Constructors

Constructor and Description
ChannelSendOperator(<any> source, java.util.function.Function<<any>,<any>> writeFunction)

Method Summary

Modifier and Type	Method and Description
void	subscribe(<any> s)

Methods inherited from class java.lang.Object

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

Field Detail

writeFunction

private final java.util.function.Function<<any>,<any>> writeFunction

Constructor Detail

ChannelSendOperator

public ChannelSendOperator(<any> source,
                           java.util.function.Function<<any>,<any>> writeFunction)

Method Detail

subscribe

public void subscribe(<any> s)