CompressorProducerMiddleware.Invoke method
public Task Invoke(IMessageContext context, MiddlewareDelegate next)
See Also
- class CompressorProducerMiddleware
- namespace KafkaFlow.Middlewares.Compressor
public Task Invoke(IMessageContext context, MiddlewareDelegate next)