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) {