Package io.gravitee.gateway.jupiter.api.message

Interface MessageFlow

public interface MessageFlow

Method Summary

Modifier and Type	Method	Description
io.reactivex.Completable	consume()
io.reactivex.Completable	flow(io.reactivex.Flowable<Message> messageFlow)
io.reactivex.Completable	onMessage(io.reactivex.FlowableTransformer<Message,Message> messagesTransformer)

Method Detail

flow

io.reactivex.Completable flow(io.reactivex.Flowable<Message> messageFlow)

onMessage

io.reactivex.Completable onMessage(io.reactivex.FlowableTransformer<Message,Message> messagesTransformer)

consume

io.reactivex.Completable consume()