Package com.mongodb.stitch.server.services.mongodb.remote

Class PassthroughChangeStream<DocumentT>

java.lang.Object

com.mongodb.stitch.core.services.mongodb.remote.ChangeStream<ChangeEvent<DocumentT>,DocumentT>

com.mongodb.stitch.server.services.mongodb.remote.PassthroughChangeStream<DocumentT>

Type Parameters:

DocumentT - The type of full document on the change event.

All Implemented Interfaces:

Closeable, AutoCloseable

public class PassthroughChangeStream<DocumentT>
extends ChangeStream<ChangeEvent<DocumentT>,DocumentT>

Simple ChangeStream implementation that unwraps and returns the same change event provided on the internal StitchEvent.

Constructor Summary

Constructors

Constructor	Description
PassthroughChangeStream(Stream<ChangeEvent<DocumentT>> stream)	Initializes a passthrough change stream with the provided underlying event stream.

Method Summary

Modifier and Type	Method	Description
ChangeEvent<DocumentT>	nextEvent()	Returns the next event available from the stream.

Methods inherited from class com.mongodb.stitch.core.services.mongodb.remote.ChangeStream

close, dispatchError, getExceptionListener, getStream, isOpen, setExceptionListener

Methods inherited from class java.lang.Object

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

Constructor Detail

PassthroughChangeStream

public PassthroughChangeStream(Stream<ChangeEvent<DocumentT>> stream)

Initializes a passthrough change stream with the provided underlying event stream.

Parameters:

stream - The event stream.

Method Detail

nextEvent

public ChangeEvent<DocumentT> nextEvent()
                                 throws IOException

Description copied from class: ChangeStream

Returns the next event available from the stream.

Specified by:

nextEvent in class ChangeStream<ChangeEvent<DocumentT>,DocumentT>

Returns:

The next event.

Throws:

IOException - If the underlying stream throws an IOException