observe

public B observe(Consumer<M> consumer)

Subscribes the passed consumer to receive messages of the subscribed type.