The return value of StreamOpusDecoder.bytes is transform. When this method is executed, the blocking operation is called in the bind method of StreamTransformerBase. As a result, when no data is passed in, it will always block and cannot be unsubscribed