perform

open suspend override fun perform(payload: SerializedPayload): RPC.StreamOrError