graham.systems
Encrypted, ephemeral, private memos on atproto
fix(consumer): use correct generator signature
+3
-3
+3
-3
packages/consumer/mod.ts
+3
-3
packages/consumer/mod.ts
···
92
92
/**
93
93
* Asynchronously iterate through items in the user's PDS
94
94
*/
95
-
async *listItems(): AsyncIterator<
95
+
async *listItems(): AsyncGenerator<
96
96
DecryptedItem,
97
97
void,
98
98
undefined
···
118
118
);
119
119
}
120
120
121
-
if (res.data.cursor) cursor = res.data.cursor;
121
+
cursor = res.data.cursor;
122
122
123
123
for (const record of res.data.records) {
124
124
const item = parse(AppCisternLexiconItem.mainSchema, record.value);
···
147
147
* Subscribes to the Jetstreams for the user's items. Pass `"stop"` into `subscription.next(...)` to cancel
148
148
* @todo Allow specifying Jetstream endpoint
149
149
*/
150
-
async *subscribeToItems(): AsyncIterator<
150
+
async *subscribeToItems(): AsyncGenerator<
151
151
DecryptedItem,
152
152
void,
153
153
"stop" | undefined