Interface SubscriptionOptions<TMessage>

interface SubscriptionOptions<TMessage extends Document> {
    filter?: Filter<TMessage>;
}

Type Parameters

  • TMessage extends Document

Properties

Properties

filter?: Filter<TMessage>

Local filter to apply on received messages (in-memory).