nonSuspendBidirectionalPayload

open override fun nonSuspendBidirectionalPayload(payloadWithStream: PayloadWithStream): Flow<Int>(source)