Package com.eventstore.dbclient

Class ConnectPersistentSubscription

java.lang.Object

com.eventstore.dbclient.ConnectPersistentSubscription

public class ConnectPersistentSubscription
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
ConnectPersistentSubscription(GrpcClient connection, java.lang.String stream, java.lang.String group, UserCredentials credentials, PersistentSubscriptionListener listener)

Method Summary

Modifier and Type	Method	Description
ConnectPersistentSubscription	authenticated(UserCredentials credentials)
java.util.concurrent.CompletableFuture	execute(int bufferSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectPersistentSubscription

public ConnectPersistentSubscription(GrpcClient connection,
                                     java.lang.String stream,
                                     java.lang.String group,
                                     UserCredentials credentials,
                                     PersistentSubscriptionListener listener)

Method Detail

authenticated

public ConnectPersistentSubscription authenticated(UserCredentials credentials)

execute

public java.util.concurrent.CompletableFuture execute(int bufferSize)