Skip to content

Commit c3481e9

Browse files
committed
chore: removed cancellation from synchronous loops
1 parent 9525363 commit c3481e9

14 files changed

+44
-74
lines changed

src/client/handlers/IdentitiesAuthenticate.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ class IdentitiesAuthenticate extends ServerHandler<
2727
_meta: Record<string, JSONValue>,
2828
ctx: ContextTimed,
2929
): AsyncGenerator<ClientRPCResponseResult<AuthProcessMessage>> {
30-
ctx.signal.throwIfAborted();
3130
const { identitiesManager }: { identitiesManager: IdentitiesManager } =
3231
this.container;
3332
const {

src/client/handlers/IdentitiesAuthenticatedGet.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@ class IdentitiesAuthenticatedGet extends ServerHandler<
2525
_meta: Record<string, JSONValue>,
2626
ctx: ContextTimed,
2727
): AsyncGenerator<ClientRPCResponseResult<IdentityMessage>> {
28-
ctx.signal.throwIfAborted();
2928
const { identitiesManager }: { identitiesManager: IdentitiesManager } =
3029
this.container;
3130
let providerId: ProviderId | undefined;

src/client/handlers/IdentitiesInfoConnectedGet.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@ class IdentitiesInfoConnectedGet extends ServerHandler<
2828
_meta: Record<string, JSONValue>,
2929
ctx: ContextTimed,
3030
): AsyncGenerator<ClientRPCResponseResult<IdentityInfoMessage>> {
31-
ctx.signal.throwIfAborted();
3231
const { identitiesManager }: { identitiesManager: IdentitiesManager } =
3332
this.container;
3433
const {

src/client/handlers/NodesGetAll.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ class NodesGetAll extends ServerHandler<
2222
_meta: Record<string, JSONValue>,
2323
ctx: ContextTimed,
2424
): AsyncGenerator<ClientRPCResponseResult<NodesGetMessage>> {
25-
ctx.signal.throwIfAborted();
2625
const { nodeGraph } = this.container;
2726
for await (const [index, bucket] of nodeGraph.getBuckets()) {
2827
for (const [id, nodeContact] of bucket) {
@@ -32,7 +31,7 @@ class NodesGetAll extends ServerHandler<
3231
yield {
3332
bucketIndex: index,
3433
nodeIdEncoded: encodedId,
35-
nodeContact,
34+
nodeContact: nodeContact,
3635
};
3736
}
3837
}

src/client/handlers/NotificationsInboxRead.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ class NotificationsInboxRead extends ServerHandler<
2626
_meta: Record<string, JSONValue>,
2727
ctx: ContextTimed,
2828
): AsyncGenerator<ClientRPCResponseResult<NotificationInboxMessage>> {
29-
ctx.signal.throwIfAborted();
3029
const {
3130
db,
3231
notificationsManager,

src/client/handlers/NotificationsOutboxRead.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ class NotificationsOutboxRead extends ServerHandler<
2626
_meta: Record<string, JSONValue>,
2727
ctx: ContextTimed,
2828
): AsyncGenerator<ClientRPCResponseResult<NotificationOutboxMessage>> {
29-
ctx.signal.throwIfAborted();
3029
const {
3130
db,
3231
notificationsManager,

src/client/handlers/VaultsList.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ class VaultsList extends ServerHandler<
2626
): AsyncGenerator<ClientRPCResponseResult<VaultListMessage>> {
2727
const { db, vaultManager }: { db: DB; vaultManager: VaultManager } =
2828
this.container;
29-
ctx.signal.throwIfAborted();
3029
const vaults = await db.withTransactionF((tran) =>
3130
vaultManager.listVaults(ctx, tran),
3231
);

src/client/handlers/VaultsLog.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ class VaultsLog extends ServerHandler<
2626
_meta: Record<string, JSONValue> | undefined,
2727
ctx: ContextTimed,
2828
): AsyncGenerator<ClientRPCResponseResult<LogEntryMessage>> {
29-
ctx.signal.throwIfAborted();
3029
const { db, vaultManager }: { db: DB; vaultManager: VaultManager } =
3130
this.container;
3231
const log = await db.withTransactionF(async (tran) => {

src/client/handlers/VaultsPermissionGet.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@ class VaultsPermissionGet extends ServerHandler<
3232
_meta: Record<string, JSONValue> | undefined,
3333
ctx: ContextTimed,
3434
): AsyncGenerator<ClientRPCResponseResult<VaultPermissionMessage>> {
35-
ctx.signal.throwIfAborted();
3635
const {
3736
db,
3837
vaultManager,

src/client/handlers/VaultsScan.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ class VaultsScan extends ServerHandler<
2626
_meta: Record<string, JSONValue> | undefined,
2727
ctx: ContextTimed,
2828
): AsyncGenerator<ClientRPCResponseResult<VaultsScanMessage>> {
29-
ctx.signal.throwIfAborted();
3029
const { vaultManager }: { vaultManager: VaultManager } = this.container;
3130
const { nodeId }: { nodeId: NodeId } = validateSync(
3231
(keyPath, value) => {

0 commit comments

Comments
 (0)