def METHOD_NAME(self):
    model_id = 'damo/speech_dfsmn_ans_psm_48k_causal'
    ans = pipeline(
        Tasks.acoustic_noise_suppression, model=model_id, stream_mode=True)
    with open(os.path.join(os.getcwd(), NOISE_SPEECH_FILE_48K_PCM),
              'rb') as f:
        block_size = 3840
        audio = f.read(block_size)
        with open('output.pcm', 'wb') as w:
            while len(audio) >= block_size:
                result = ans(audio)
                pcm = result[OutputKeys.OUTPUT_PCM]
                w.write(pcm)
                audio = f.read(block_size)