Function requestInputToResponse$

http/src/http-driver.ts:135–147

(reqInput: RequestInput)

export type ResponseMemoryStream = MemoryStream<Response> & ResponseStream;

function requestInputToResponse$(reqInput: RequestInput): ResponseMemoryStream {
  let response$ = createResponse$(reqInput).remember();
  const reqOptions = softNormalizeRequestInput(reqInput);
  if (!reqOptions.lazy) {
    response$.addListener({next: () => {}, error: () => {}, complete: () => {}});
  }
  response$ = adapt(response$);
  Object.defineProperty(response$, 'request', {
    value: reqOptions,
    writable: false,
  });
  return response$ as ResponseMemoryStream;
};

export function makeHTTPDriver(): DriverFunction {
  function httpDriver(request$: Stream<RequestInput>, name: string): HTTPSource {