Output
Every Marble.js listener factory allows you to intercept outgoing messages via dedicated output$ handler.
Using
HttpOutputEffect you can grab an outgoing Effect response and map it into different one, modifying outgoing data on demand.type Out = {
request: HttpRequest;
headers: HttpHeaders;
status: HttpStatus;
body: any;
};
HttpOutputEffect :: Observable<Out> -> Observable<Out>
HttpOutputEffect allows you to grab the outgoing response together with corresponding initial request. The output effect works similar to the HttpMiddlewareEffect, but in that case for outgoing responses. Let's build a simple response compression middleware.output.effect.ts
import { HttpOutputEffect } from '@marblejs/http';
import { map } from 'rxjs/operators';
import * as zlib from 'zlib';
const output$: HttpOutputEffect = res$ =>
res$.pipe(
map(({ request, headers, body, status }) => {
switch(request.headers['accept-encoding']) {
case 'br':
return ({
request,
status,
headers: { ...headers, 'Content-Encoding': 'br' },
body: body.pipe(zlib.createBrotliDecompress()),
});
case 'gzip':
return ({
request,
status,
headers: { ...headers, 'Content-Encoding': 'gzip' },
body: body.pipe(zlib.createGunzip()),
});
case 'deflate':
return ({
request,
status,
headers: { ...headers, 'Content-Encoding': 'deflate' },
body: body.pipe(zlib.createInflate()),
});
default:
return { status, headers, body, request };
}
}),
);
To connect the output effect, all you need to do is to attach it to
output$ property in httpListener config object.import { httpListener } from '@marblejs/http';
import { output$ } from './output.effect';
export const listener = httpListener({
middlewares: [ ... ],
effects: [ ... ],
output$, // 👈
});
Last modified 1yr ago