def METHOD_NAME(self) -> None:
    """Part of IProducer interface"""
    self._producer = None
    assert self._finished_deferred is not None
    if not self._finished_deferred.called:
        self._bytes_queue.put_nowait(None)