handleStreamMessage

suspend fun handleStreamMessage(message: DestinationStreamAffinedMessage, postProcessingCallback: suspend () -> Unit = {}): PipelineInputEvent