Introduce ResultStreamPublisher to interact with a ResultStream through a Publisher.

[saratry]

No description provided.

[abuijze]

A few recommendations to simplify things.

[abuijze]

Having callbacks triggered to an object that hasn't been constructed completely yet is generally not recommended.
In a comparable situation, we have chosen to register this callback in the request method, with the following pseudo-code:

  if (requested.getAndUpdate(prev -> prev + n) == 0) {
      this.resultStream.onAvailable(this::signal);
  } 
  signal();
}

The resultstream will only remember the last registered callback, so there is only very little overhead in this operation.

[saratry]

what about moving that line into afterSubscribe method?

private void afterSubscribe() {
    this.resultStream.onAvailable(this::signal);
    signal();
}

In this way, it is executed only once.

[smcvb]

A bunch of minor pointers to chat about.
And, don't forget the code smell SonarCloud marked.
It's about the generic name you've used, so I would anticipate it to be resolved after processing the comments anyhow.

[sonarcloud]

Kudos, SonarCloud Quality Gate passed!   

0 Bugs
0 Vulnerabilities
0 Security Hotspots
0 Code Smells

78.4% Coverage
0.0% Duplication

[smcvb]

My concerns have been addressed, hence approving.