perform

open suspend override fun perform(payload: SerializedPayload, stream: Flow<SerializedPayload>): SerializedPayload