Skip to content

Commit b9f7e8e

Browse files
committed
fix: more flexible option types
1 parent 0b27e7e commit b9f7e8e

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

src/stream.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ export class RedisStream<T extends Mode = 'entry'> {
3232
public count = 100
3333
public noack = false
3434
public block?: number
35-
public buffers?: boolean = false
35+
public buffers = false
3636

3737
//behavior
3838
public ackOnIterate = false

src/types.ts

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ export interface RedisStreamOptions<T extends Mode> {
7878
* Return buffers with each xread operation
7979
* This applies to entry id and kv results
8080
*/
81-
buffers?: true
81+
buffers?: boolean
8282
/**
8383
* The maximum number of entries to retrieve in a single read operation
8484
* eg. the "highWaterMark"
@@ -93,20 +93,20 @@ export interface RedisStreamOptions<T extends Mode> {
9393
/**
9494
* If set to `true` Iterables utilizing consumer groups will
9595
* automatically queue acknowledgments for previously iterated entries.
96-
* @default undefined
96+
* @default false
9797
*/
98-
ackOnIterate?: true
98+
ackOnIterate?: boolean
9999
/**
100100
* If set to `true` Iterables utilizing consumer groups will
101101
* automatically delete entries after acknowledgment
102-
* @default undefined
102+
* @default false
103103
*/
104-
deleteOnAck?: true
104+
deleteOnAck?: boolean
105105
/**
106106
* Pass the NOACK flag to calls to xreadgroup bypassing the Redis PEL
107-
* @default `false`
107+
* @default false
108108
*/
109-
noack?: true
109+
noack?: boolean
110110
/**
111111
* The number of entries to buffer for acknowledgment at the same time.
112112
* Removes items from the Redis PEL

0 commit comments

Comments
 (0)