allMessagesStream abstract method

Stream<PayloadWithTopic> allMessagesStream()

Implementation

Stream<PayloadWithTopic> allMessagesStream();