StreamProcessor: ((message) => StatusResult)

Function type for processing messages

Type declaration