org.jboss.resteasy.microprofile.client.publisher

Class SSEPublisher<T>

java.lang.Object

org.jboss.resteasy.microprofile.client.publisher.SSEPublisher<T>

Type Parameters:

T - the type of event.

All Implemented Interfaces:

org.reactivestreams.Publisher<T>

public class SSEPublisher<T>
extends Object
implements org.reactivestreams.Publisher<T>

Publisher implementation emitting server-sent-event downstream.

Constructor Summary

Constructors

Constructor and Description
SSEPublisher(Type genericType, javax.ws.rs.ext.Providers providers, SseEventInputImpl input, ExecutorService es)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super T> downstream)

Methods inherited from class java.lang.Object

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

Constructor Detail

SSEPublisher

public SSEPublisher(Type genericType,
                    javax.ws.rs.ext.Providers providers,
                    SseEventInputImpl input,
                    ExecutorService es)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super T> downstream)

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>