fix: rename sendChunk in sendBuffer (#141)

icappello · web-flow · commit 81204cb8d8af · 2024-01-09T10:24:10.000+01:00
diff --git a/src/producer.ts b/src/producer.ts
@@ -121,7 +121,7 @@ export class StreamProducer implements Producer {
   }
 
   async flush() {
-    await this.sendChunk()
+    await this.sendBuffer()
     return true
   }
 
@@ -181,7 +181,7 @@ export class StreamProducer implements Producer {
     const sendCycleNeeded = this.add(publishRequestMessage)
     let sent = false
     if (sendCycleNeeded) {
-      await this.sendChunk()
+      await this.sendBuffer()
       sent = true
     }
     this.scheduleIfNeeded()
@@ -198,7 +198,7 @@ export class StreamProducer implements Producer {
     return true
   }
 
-  private async sendChunk() {
+  private async sendBuffer() {
     const chunk = this.popChunk()
     if (chunk.length > 0) {
       await this.client.send(

Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,7 @@ export class StreamProducer implements Producer {`
`121`	`121`	`}`
`122`	`122`
`123`	`123`	`async flush() {`
`124`		`- await this.sendChunk()`
	`124`	`+ await this.sendBuffer()`
`125`	`125`	`return true`
`126`	`126`	`}`
`127`	`127`
`@@ -181,7 +181,7 @@ export class StreamProducer implements Producer {`
`181`	`181`	`const sendCycleNeeded = this.add(publishRequestMessage)`
`182`	`182`	`let sent = false`
`183`	`183`	`if (sendCycleNeeded) {`
`184`		`- await this.sendChunk()`
	`184`	`+ await this.sendBuffer()`
`185`	`185`	`sent = true`
`186`	`186`	`}`
`187`	`187`	`this.scheduleIfNeeded()`
`@@ -198,7 +198,7 @@ export class StreamProducer implements Producer {`
`198`	`198`	`return true`
`199`	`199`	`}`
`200`	`200`
`201`		`- private async sendChunk() {`
	`201`	`+ private async sendBuffer() {`
`202`	`202`	`const chunk = this.popChunk()`
`203`	`203`	`if (chunk.length > 0) {`
`204`	`204`	`await this.client.send(`