perf: drop streamx (#2462)

webtorrent · Jan 28, 2023 · cde79ed · cde79ed
1 parent 86ac634
commit cde79ed
Showing 1 changed file with 14 additions and 12 deletions.
diff --git a/lib/peer.js b/lib/peer.js
@@ -1,5 1,5 @@
 import EventEmitter from 'events'
-import { Transform } from 'stream'
 import { Transform, pipeline } from 'streamx'
 import arrayRemove from 'unordered-array-remove'
 import debugFactory from 'debug'
 import Wire from 'bittorrent-protocol'
@@ -181,25 181,27 @@ export default class Peer extends EventEmitter {
 
  setThrottlePipes () {
  const self = this
- this.conn
- .pipe(this.throttleGroups.down.throttle())
- .pipe(new Transform({
- transform (chunk, _, callback) {
  pipeline(
  this.conn,
  this.throttleGroups.down.throttle(),
  new Transform({
  transform (chunk, callback) {
  self.emit('download', chunk.length)
  if (self.destroyed) return
  callback(null, chunk)
  }
- }))
- .pipe(this.wire)
- .pipe(this.throttleGroups.up.throttle())
- .pipe(new Transform({
- transform (chunk, _, callback) {
  }),
  this.wire,
  this.throttleGroups.up.throttle(),
  new Transform({
  transform (chunk, callback) {
  self.emit('upload', chunk.length)
  if (self.destroyed) return
  callback(null, chunk)
  }
- }))
- .pipe(this.conn)
  }),
  this.conn
  )
  }
 
  /**