@@ -213,29 +213,6 @@ export class DocumentSubscriptions implements IDisposable {
213213 public getSubscriptionWorkerForRevisions < T extends object > (
214214 options : SubscriptionWorkerOptions < T > , database : string ) : SubscriptionWorker < Revision < T > > ;
215215
216- /**
217- * It opens a subscription and starts pulling documents since a last processed document for that subscription.
218- * The connection options determine client and server cooperation rules like document batch sizes
219- * or a timeout in a matter of which a client needs to acknowledge that batch has been processed.
220- * The acknowledgment is sent after all documents are processed by subscription's handlers.
221- *
222- * There can be only a single client that is connected to a subscription.
223- */
224- public getSubscriptionWorkerForRevisions < T extends object > (
225- subscriptionName : string , documentType : DocumentType < T > ) : SubscriptionWorker < Revision < T > > ;
226-
227- /**
228- * It opens a subscription and starts pulling documents since a last processed document for that subscription.
229- * The connection options determine client and server cooperation rules like document batch sizes
230- * or a timeout in a matter of which a client needs to acknowledge that batch has been processed.
231- * The acknowledgment is sent after all documents are processed by subscription's handlers.
232- *
233- * There can be only a single client that is connected to a subscription.
234- */
235- public getSubscriptionWorkerForRevisions < T extends object > (
236- subscriptionName : string , documentType : DocumentType < T > ,
237- database : string ) : SubscriptionWorker < Revision < T > > ;
238-
239216 /**
240217 * It opens a subscription and starts pulling documents since a last processed document for that subscription.
241218 * The connection options determine client and server cooperation rules like document batch sizes
@@ -246,18 +223,15 @@ export class DocumentSubscriptions implements IDisposable {
246223 */
247224 public getSubscriptionWorkerForRevisions < T extends object > (
248225 optionsOrSubscriptionName : SubscriptionWorkerOptions < T > | string ,
249- documentTypeOrDatabase ?: DocumentType < T > | string ,
250226 database ?: string ) : SubscriptionWorker < Revision < T > > {
251227
252228 if ( TypeUtil . isString ( optionsOrSubscriptionName ) ) {
253229 return this . getSubscriptionWorkerForRevisions ( {
254230 subscriptionName : optionsOrSubscriptionName ,
255- documentType : documentTypeOrDatabase
256231 } as SubscriptionWorkerOptions < T > , database ) ;
257232 }
258233
259234 const options : SubscriptionWorkerOptions < T > = optionsOrSubscriptionName ;
260- database = documentTypeOrDatabase as string ;
261235 const subscription = new SubscriptionWorker < Revision < T > > (
262236 options as any as SubscriptionWorkerOptions < Revision < T > > , true , this . _store , database ) ;
263237
0 commit comments