renaming things for consistency

Author: alunyov

packages/react-server-dom-fb/src/__tests__/ReactFlightDOMServerFB-test.internal.js

@@ -31,21 +31,29 @@ let Suspense;
 let registerClientReference;
 
 class Destination {
+  #buffer = '';
+  #controller = null;
   constructor() {
     const self = this;
     this.stream = new ReadableStream({
       start(controller) {
-        self._controller = controller;
+        self.#controller = controller;
       },
     });
   }
   write(chunk) {
-    this._controller.enqueue(chunk);
+    this.#buffer += chunk;
+  }
+  beginWriting() {}
+  completeWriting() {}
+  flushBuffered() {
+    if (!this.#controller) {
+      throw new Error('Expected a controller.');
+    }
+    this.#controller.enqueue(this.#buffer);
+    this.#buffer = '';
   }
   close() {}
-  flush() {}
-  onStart() {}
-  onComplete() {}
   onError() {}
 }
 

packages/react-server/src/forks/ReactServerStreamConfig.dom-fb-experimental.js

@@ -16,23 +16,20 @@ import type {
 } from '../ReactServerStreamConfigFB';
 
 export interface Destination {
+  beginWriting(): void;
   write(chunk: Chunk | PrecomputedChunk | BinaryChunk): void;
+  completeWriting(): void;
+  flushBuffered(): void;
   close(): void;
-  flush(): void;
-  onStart(): void;
-  onComplete(): void;
   onError(error: mixed): void;
 }
 
 export function scheduleWork(callback: () => void) {
   callback();
 }
 
-export function flushBuffered(destination: Destination) {
-  destination.flush();
-}
 export function beginWriting(destination: Destination) {
-  destination.onStart();
+  destination.beginWriting();
 }
 
 export function writeChunk(
@@ -51,7 +48,11 @@ export function writeChunkAndReturn(
 }
 
 export function completeWriting(destination: Destination) {
-  destination.onComplete();
+  destination.completeWriting();
+}
+
+export function flushBuffered(destination: Destination) {
+  destination.flushBuffered();
 }
 
 export function close(destination: Destination) {