Package org.infinispan.rest

Class EventStream

java.lang.Object

org.infinispan.rest.EventStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class EventStream
extends Object
implements Closeable

Since:

13.0

Author:

Tristan Tarrant <tristan@infinispan.org>

Constructor Summary

Constructors

Constructor	Description
EventStream(Consumer<EventStream> onOpen, Runnable onClose)

Method Summary

Modifier and Type	Method	Description
void	close()
CompletionStage<Void>	sendEvent(ServerSentEvent e)
void	setChannelHandlerContext(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class java.lang.Object

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

Constructor Details

EventStream

public EventStream(Consumer<EventStream> onOpen,
 Runnable onClose)

Method Details

sendEvent

public CompletionStage<Void> sendEvent(ServerSentEvent e)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

setChannelHandlerContext

public void setChannelHandlerContext(io.netty.channel.ChannelHandlerContext ctx)