+ errors = new Subject<Error>()
+ warnings = new Subject<Error>()
+
+ // TODO: use WebTorrent @type
+ // private client: WebTorrent.Client
+ private client: any
+
+ constructor () {
+ this.client = new WebTorrent({ dht: false })
+
+ this.client.on('error', (err) => this.errors.next(err))
+ this.client.on('warning', (err) => this.warnings.next(err))
+ }