Package com.zb.mom.ww.mxgateway.client

Class DeployEventStream

java.lang.Object

com.zb.mom.ww.mxgateway.client.DeployEventStream

All Implemented Interfaces:

AutoCloseable, Iterator<GalaxyRepositoryOuterClass.DeployEvent>

public final class DeployEventStream
extends Object
implements Iterator<GalaxyRepositoryOuterClass.DeployEvent>, AutoCloseable

Iterator-style adaptor over the WatchDeployEvents server-streaming RPC. Mirrors MxEventStream: events arrive on a background gRPC thread and are buffered in a bounded blocking queue; the iterator drains them. Closing the stream cancels the underlying gRPC call.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
GalaxyRepositoryOuterClass.DeployEvent	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Method Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<GalaxyRepositoryOuterClass.DeployEvent>

next

public GalaxyRepositoryOuterClass.DeployEvent next()

Specified by:

next in interface Iterator<GalaxyRepositoryOuterClass.DeployEvent>

close

public void close()

Specified by:

close in interface AutoCloseable