Modifier and Type	Class and Description
private static class	OutputStreamPublisher.OutputStreamSubscription

Modifier and Type	Field and Description
private final DataBufferFactory	bufferFactory
private final int	chunkSize
private final Executor	executor
private final Consumer<OutputStream>	outputStreamConsumer

Access	Constructor and Description
pack-priv	OutputStreamPublisher(Consumer<OutputStream> outputStreamConsumer, DataBufferFactory bufferFactory, Executor executor, int chunkSize)

Modifier and Type	Method and Description
public void	subscribe(Subscriber<? super DataBuffer> the `Subscriber` that will consume signals from this `Publisher` subscriber) Implements org.reactivestreams.Publisher.subscribe. Request `Publisher` to start streaming data.

bufferFactory	back to summary
private final DataBufferFactory bufferFactory

chunkSize	back to summary
private final int chunkSize

executor	back to summary
private final Executor executor

outputStreamConsumer	back to summary
private final Consumer<OutputStream> outputStreamConsumer

OutputStreamPublisher	back to summary
pack-priv OutputStreamPublisher(Consumer<OutputStream> outputStreamConsumer, DataBufferFactory bufferFactory, Executor executor, int chunkSize)

subscribe	back to summary
public void subscribe(Subscriber<? super DataBuffer> subscriber) Implements org.reactivestreams.Publisher.subscribe. Doc from org.reactivestreams.Publisher.subscribe. Request `Publisher` to start streaming data. This is a "factory method" and can be called multiple times, each time starting a new `Subscription`. Each `Subscription` will work for only a single `Subscriber`. A `Subscriber` should only subscribe once to a single `Publisher`. If the `Publisher` rejects the subscription attempt or otherwise fails it will signal the error via `Subscriber#onError(Throwable)`. Parameters subscriber:Subscriber<? super DataBuffer> the `Subscriber` that will consume signals from this `Publisher` Annotations @Override

org.springframework.core.io.buffer back to summary

private final Class OutputStreamPublisher.OutputStreamSubscription

Class Inheritance

extends OutputStream
implements Subscription

java.lang.Object
java.io.OutputStream
org.springframework.core.io.buffer.OutputStreamPublisher.OutputStreamSubscription

All Implemented Interfaces

org.reactivestreams.Subscription

Field Summary

Modifier and Type	Field and Description
private final Subscriber<? super DataBuffer>	actual
private final DataBufferFactory	bufferFactory
private final int	chunkSize
private volatile Throwable	error
private final Consumer<OutputStream>	outputStreamHandler
private final AtomicReference<Object>	parkedThread
private long	produced
private static final Object	READY
private final AtomicLong	requested

Constructor Summary

Access	Constructor and Description
pack-priv	OutputStreamSubscription(Subscriber<? super DataBuffer> actual, Consumer<OutputStream> outputStreamConsumer, DataBufferFactory bufferFactory, int chunkSize)

Method Summary

Modifier and Type	Method and Description
private long	addCap(long n)
private static long	addCap(long a, long b)
private void	await()
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
private void	checkDemandAndAwaitIfNeeded()
private void	invokeHandler()
private static boolean	isCancelled(long state)
private static boolean	isTerminated(long state)
public void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.
private void	resume()
private long	tryCancel()
private long	tryProduce(long n)
private long	tryTerminate()
public void	write(int the `byte`. b) Implements abstract java.io.OutputStream.write. Writes the specified byte to this output stream.
public void	write(byte[] the data. b) Overrides java.io.OutputStream.write. Writes `b.length` bytes from the specified byte array to this output stream.
public void	write(byte[] the data. b, int the start offset in the data. off, int the number of bytes to write. len) Overrides java.io.OutputStream.write. Writes `len` bytes from the specified byte array starting at offset `off` to this output stream.

Inherited from java.io.OutputStream:: close flush nullOutputStream

Field Detail

actual	back to summary
private final Subscriber<? super DataBuffer> actual

bufferFactory	back to summary
private final DataBufferFactory bufferFactory

chunkSize	back to summary
private final int chunkSize

error	back to summary
private volatile Throwable error Annotations @Nullable

outputStreamHandler	back to summary
private final Consumer<OutputStream> outputStreamHandler

parkedThread	back to summary
private final AtomicReference<Object> parkedThread

produced	back to summary
private long produced

READY	back to summary
private static final Object READY

requested	back to summary
private final AtomicLong requested

Constructor Detail

OutputStreamSubscription	back to summary
pack-priv OutputStreamSubscription(Subscriber<? super DataBuffer> actual, Consumer<OutputStream> outputStreamConsumer, DataBufferFactory bufferFactory, int chunkSize)

Method Detail

addCap	back to summary
private long addCap(long n)

addCap	back to summary
private static long addCap(long a, long b)

await	back to summary
private void await()

cancel back to summary

cancel	back to summary
public void cancel() Implements org.reactivestreams.Subscription.cancel. Doc from org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources. Data may still be sent to meet previously signalled demand after calling cancel. Annotations @Override

public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

checkDemandAndAwaitIfNeeded	back to summary
private void checkDemandAndAwaitIfNeeded() throws IOException

invokeHandler	back to summary
private void invokeHandler()

isCancelled	back to summary
private static boolean isCancelled(long state)

isTerminated	back to summary
private static boolean isTerminated(long state)

request back to summary

request	back to summary
public void request(long n) Implements org.reactivestreams.Subscription.request. Doc from org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method. It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the `Publisher` as "effectively unbounded". Whatever has been requested can be sent by the `Publisher` so only signal demand for what can be safely handled. A `Publisher` can send less than is requested if the stream ends but then must emit either `Subscriber#onError(Throwable)` or `Subscriber#onComplete()`. Parameters n:long the strictly positive number of elements to requests to the upstream `Publisher` Annotations @Override

public void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

resume	back to summary
private void resume()

tryCancel	back to summary
private long tryCancel()

tryProduce	back to summary
private long tryProduce(long n)

tryTerminate	back to summary
private long tryTerminate()

write back to summary

write	back to summary
public void write(int b) throws IOException Implements abstract java.io.OutputStream.write. Doc from java.io.OutputStream.write. Writes the specified byte to this output stream. The general contract for `write` is that one byte is written to the output stream. The byte to be written is the eight low-order bits of the argument `b`. The 24 high-order bits of `b` are ignored. Parameters b:int the `byte`. Annotations @Override Exceptions IOException: if an I/O error occurs. In particular, an `IOException` may be thrown if the output stream has been closed.

public void write(int b) throws IOException

Implements abstract java.io.OutputStream.write.

Doc from java.io.OutputStream.write.

Writes the specified byte to this output stream. The general contract for write is that one byte is written to the output stream. The byte to be written is the eight low-order bits of the argument b. The 24 high-order bits of b are ignored.

Parameters

b:int: the byte.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

write back to summary

write	back to summary
public void write(byte[] b) throws IOException Overrides java.io.OutputStream.write. Doc from java.io.OutputStream.write. Writes `b.length` bytes from the specified byte array to this output stream. The general contract for `write(b)` is that it should have exactly the same effect as the call `write(b, 0, b.length)`. Parameters b:byte[] the data. Annotations @Override Exceptions IOException: if an I/O error occurs.

public void write(byte[] b) throws IOException

Overrides java.io.OutputStream.write.

Doc from java.io.OutputStream.write.

Writes b.length bytes from the specified byte array to this output stream. The general contract for write(b) is that it should have exactly the same effect as the call write(b, 0, b.length).

Parameters

b:byte[]: the data.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

write back to summary

write	back to summary
public void write(byte[] b, int off, int len) throws IOException Overrides java.io.OutputStream.write. Doc from java.io.OutputStream.write. Writes `len` bytes from the specified byte array starting at offset `off` to this output stream. The general contract for `write(b, off, len)` is that some of the bytes in the array `b` are written to the output stream in order; element `b[off]` is the first byte written and `b[off+len-1]` is the last byte written by this operation. If `b` is `null`, a `NullPointerException` is thrown. If `off` is negative, or `len` is negative, or `off+len` is greater than the length of the array `b`, then an `IndexOutOfBoundsException` is thrown. Parameters b:byte[] the data. off:int the start offset in the data. len:int the number of bytes to write. Annotations @Override Exceptions IOException: if an I/O error occurs. In particular, an `IOException` is thrown if the output stream is closed.

public void write(byte[] b, int off, int len) throws IOException

Overrides java.io.OutputStream.write.

Doc from java.io.OutputStream.write.

Writes len bytes from the specified byte array starting at offset off to this output stream. The general contract for write(b, off, len) is that some of the bytes in the array b are written to the output stream in order; element b[off] is the first byte written and b[off+len-1] is the last byte written by this operation.

If b is null, a NullPointerException is thrown.

If off is negative, or len is negative, or off+len is greater than the length of the array b, then an IndexOutOfBoundsException is thrown.

Parameters

b:byte[]: the data.
off:int: the start offset in the data.
len:int: the number of bytes to write.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs. In particular, an IOException is thrown if the output stream is closed.

pack-priv final Class OutputStreamPublisher

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class OutputStreamPublisher.OutputStreamSubscription

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail