change(jetstream): JetStreamClient#pull() was deprecated and has been…

… removed. Use Consumer#next().

Signed-off-by: Alberto Ricart <[email protected]>

jetstream/src/jsclient.ts

@@ -298,34 +298,6 @@ export class JetStreamClientImpl extends BaseApiClientImpl
     return pa;
   }
 
-  async pull(stream: string, durable: string, expires = 0): Promise<JsMsg> {
-    validateStreamName(stream);
-    validateDurableName(durable);
-
-    let timeout = this.timeout;
-    if (expires > timeout) {
-      timeout = expires;
-    }
-
-    expires = expires < 0 ? 0 : nanos(expires);
-    const pullOpts: Partial<PullOptions> = {
-      batch: 1,
-      no_wait: expires === 0,
-      expires,
-    };
-
-    const msg = await this.nc.request(
-      `${this.prefix}.CONSUMER.MSG.NEXT.${stream}.${durable}`,
-      this.jc.encode(pullOpts),
-      { noMux: true, timeout },
-    );
-    const err = checkJsError(msg);
-    if (err) {
-      throw err;
-    }
-    return toJsMsg(msg, this.timeout);
-  }
-
   /*
    * Returns available messages upto specified batch count.
    * If expires is set the iterator will wait for the specified

jetstream/src/types.ts

@@ -731,15 +731,6 @@ export interface JetStreamClient {
     options?: Partial<JetStreamPublishOptions>,
   ): Promise<PubAck>;
 
-  /**
-   * Retrieves a single message from JetStream
-   * @param stream - the name of the stream
-   * @param consumer - the consumer's durable name (if durable) or name if ephemeral
-   * @param expires - the number of milliseconds to wait for a message
-   * @deprecated - use {@link Consumer#fetch()}
-   */
-  pull(stream: string, consumer: string, expires?: number): Promise<JsMsg>;
-
   /**
    * Similar to pull, but able to configure the number of messages, etc. via PullOptions.
    * @param stream - the name of the stream