def unsubscribe_from_data(
        self,
        subscriber: Callable[[bytes], bool],
    ) -> None:
        """
        Not thread-safe.

        """
        self._data_subscribers.remove(subscriber)