Module methanol

Package com.github.mizosoft.methanol.internal.extensions

Class HttpResponsePublisher<T>

java.lang.Object

com.github.mizosoft.methanol.internal.extensions.HttpResponsePublisher<T>

All Implemented Interfaces:

Flow.Publisher<HttpResponse<T>>

public final class HttpResponsePublisher<T>
extends Object
implements Flow.Publisher<HttpResponse<T>>

A publisher of responses resulting from sending a given request and optionally accepting incoming push promises, if any.

Constructor Summary

Constructors

Constructor	Description
HttpResponsePublisher(HttpClient client, HttpRequest request, HttpResponse.BodyHandler<T> bodyHandler, @Nullable Function<HttpRequest,@Nullable HttpResponse.BodyHandler<T>> pushPromiseMapper, Executor executor)	Creates a new HttpResponsePublisher.

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super HttpResponse<T>> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Details

HttpResponsePublisher

public HttpResponsePublisher(HttpClient client,
 HttpRequest request,
 HttpResponse.BodyHandler<T> bodyHandler,
 @Nullable Function<HttpRequest,@Nullable HttpResponse.BodyHandler<T>> pushPromiseMapper,
 Executor executor)

Creates a new HttpResponsePublisher. If pushPromiseMapper is null, all push promises are rejected.

Method Details

subscribe

public void subscribe(Flow.Subscriber<? super HttpResponse<T>> subscriber)

Specified by:

subscribe in interface Flow.Publisher<T>