Revert "feat: add postBody Functionality"

This reverts commit 73e1a3a.

README.md

@@ -19,7 +19,6 @@ Library supports all instructions that the Ledge parser supports. Also supports
     - [varsCookieBlacklist](#varscookieblacklist)
   - [Custom ESI Vars Function](#custom-esi-vars-function)
   - [Custom Fetch Function](#custom-fetch-function)
-  - [Optional Post Body Function](#optional-post-body-function)
 - [Caching and upstream requests](#caching-and-upstream-requests)
 - [Edge Side Includes](#edge-side-includes)
   - [Regular expressions in conditions](#regular-expressions-in-conditions)
@@ -59,7 +58,6 @@ new esi(
    options?: // Config
    customESIFunction?: // Custom ESI Vars Function
    fetcher?: // Custom Fetch Function
-   postBodyFunction?: // Optional function that will be called once the body has been completed
 )
 ```
 
@@ -247,10 +245,6 @@ new esi(undefined, undefined, customFetcher)
 ```
 
 
-### Optional Post Body Function
-
-If you need to do extra work once the body has completed streaming, eg you record how many fetches your custom fetcher handles. Or need to fire off some context.waitUntil functions at the end you can fire them after this function has been called.
-
 
 ## Caching and upstream requests
 

src/index.ts

@@ -103,7 +103,6 @@ export type customESIVarsFunction = (
   request: Request,
 ) => Promise<customESIVars>;
 export type fetchFunction = (request: string | Request) => Promise<Response>;
-export type postBodyFunction = () => void | Promise<void>;
 
 const processorToken = "ESI";
 const processorVersion = 1.0;
@@ -112,22 +111,19 @@ export class esi {
   options: ESIConfig;
   esiFunction?: customESIVarsFunction;
   fetcher: fetchFunction;
-  postBodyFunction?: postBodyFunction;
 
   constructor(
     options?: ESIConfig,
     customESIFunction?: customESIVarsFunction,
     fetcher = fetch as fetchFunction,
-    postBodyFunction?: postBodyFunction,
   ) {
     const defaultConfig = {
       recursionLimit: 10,
       contentTypes: ["text/html", "text/plain"],
     };
     this.options = { ...defaultConfig, ...options };
     this.fetcher = fetcher;
-    this.esiFunction = customESIFunction;
-    this.postBodyFunction = postBodyFunction;
+    if (customESIFunction) this.esiFunction = customESIFunction;
   }
 
   async parse(origRequest: Request, recursion = 0): Promise<Response> {
@@ -256,7 +252,7 @@ export class esi {
     /**
      * Flushes output to the Writeable Stream
      */
-    const flush_output = async () => {
+    async function flush_output() {
       // Can't call this if we're waiting for an sync option to complete
       if (pending) {
         return;
@@ -291,13 +287,8 @@ export class esi {
       if (ended && output.length === 0) {
         const writer = writable.getWriter();
         await writer.close();
-
-        // we're completely done now notify the post body function
-        if (this.postBodyFunction) {
-          this.postBodyFunction();
-        }
       }
-    };
+    }
 
     const writer = (text: string, esi: boolean) => {
       if (esi) {