Gotta be @injectable()

Author: mondoreale

packages/sdk/src/subscribe/Resends.ts

@@ -13,7 +13,7 @@ import {
 import random from 'lodash/random'
 import sample from 'lodash/sample'
 import without from 'lodash/without'
-import { delay, inject } from 'tsyringe'
+import { delay, inject, injectable } from 'tsyringe'
 import { ConfigInjectionToken, type StrictStreamrClientConfig } from '../ConfigTypes'
 import { StreamrClientError } from '../StreamrClientError'
 import { StorageNodeRegistry } from '../contracts/StorageNodeRegistry'
@@ -119,6 +119,7 @@ export const toInternalResendOptions = (options: ResendOptions): InternalResendO
     }
 }
 
+@injectable()
 export class Resends {
 
     private readonly storageNodeRegistry: StorageNodeRegistry

packages/sdk/src/subscribe/Subscriber.ts

@@ -1,11 +1,12 @@
 import { EthereumAddress, Logger, StreamPartID } from '@streamr/utils'
-import { delay, inject } from 'tsyringe'
+import { delay, inject, injectable } from 'tsyringe'
 import { NetworkNodeFacade } from '../NetworkNodeFacade'
 import { LoggerFactory } from '../utils/LoggerFactory'
 import { MessagePipelineFactory } from './MessagePipelineFactory'
 import { Subscription } from './Subscription'
 import { SubscriptionSession } from './SubscriptionSession'
 
+@injectable()
 export class Subscriber {
 
     private readonly subSessions: Map<StreamPartID, SubscriptionSession> = new Map()