StreamProcessor: ((message: JsonMap) => StatusResult)

Function type for processing messages