ResultStreamPublisher (AxonServer Connector 2026.0.0 API)

java.lang.Object
- io.axoniq.axonserver.connector.ResultStreamPublisher<M>

Type Parameters:

M - the type of element consumed from the underlying stream

All Implemented Interfaces:

org.reactivestreams.Publisher<M>
```
public class ResultStreamPublisher<M>
extends Object
implements org.reactivestreams.Publisher<M>
```
Publisher implementation that allows to interact with a ResultStream.
When subscribed, it generates a new ResultStream through the provided supplier. The generated ResultStream provides the elements to be published.

Since:

4.6.0

Author:

Sara Pellegrini

Constructor Summary

Constructors
Constructor	Description
`ResultStreamPublisher(Supplier<ResultStream<M>> resultStreamSupplier)`	Constructs an instance based on the specifier supplier of underlying `ResultStream`.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

void subscribe(org.reactivestreams.Subscriber<? super M> s)
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ResultStreamPublisher
```
public ResultStreamPublisher(Supplier<ResultStream<M>> resultStreamSupplier)
```
    Constructs an instance based on the specifier supplier of underlying ResultStream.
    
    Parameters:
    
    resultStreamSupplier - supplier of ResultStream used to generate the underlying stream when the publisher is subscribed
- Method Detail
  - subscribe
```
public void subscribe(org.reactivestreams.Subscriber<? super M> s)
```
    Specified by:
    
    subscribe in interface org.reactivestreams.Publisher<M>