tuweni / org.apache.tuweni.scuttlebutt.lib / FeedService / createFeedStream

createFeedStream

fun createFeedStream(streamHandler: Function<Runnable!, StreamHandler<FeedMessage!>!>!): Unit (source)

Streams every message in the instance's database.

Parameters

streamHandler - Function<Runnable!, StreamHandler<FeedMessage!>!>!: a function that can be used to construct the handler for processing the streamed messages, using a runnable which can be ran to close the stream early.

Exceptions

JsonProcessingException - if the request to open the stream could not be made due to a JSON marshalling error.

ConnectionClosedException - if the stream could not be started because the connection is no longer open.